Added support for standalone activity termination.

Author: fretz12

chasm/lib/activity/activity.go

@@ -273,6 +273,20 @@ func (a *Activity) HandleFailed(ctx chasm.MutableContext, params RecordFailedPar
 	return &historyservice.RespondActivityTaskFailedResponse{}, nil
 }
 
+// RecordTerminatedParams holds parameters for handling termination
+type RecordTerminatedParams struct {
+	Reason         string
+	WorkerIdentity string
+}
+
+func (a *Activity) handleTerminated(ctx chasm.MutableContext, params RecordTerminatedParams) (*activitypb.TerminateActivityExecutionResponse, error) {
+	if err := TransitionTerminated.Apply(a, ctx, params); err != nil {
+		return nil, err
+	}
+
+	return &activitypb.TerminateActivityExecutionResponse{}, nil
+}
+
 func (a *Activity) shouldRetryOnFailure(ctx chasm.Context, failure *failurepb.Failure) (bool, error) {
 	isRetryable := commonfailure.IsRetryable(failure, a.GetRetryPolicy().GetNonRetryableErrorTypes())
 	if !isRetryable {

chasm/lib/activity/frontend.go

@@ -103,6 +103,27 @@ func (h *frontendHandler) PollActivityExecution(
 	return resp.GetFrontendResponse(), err
 }
 
+// TerminateActivityExecution terminates a standalone activity execution
+func (h *frontendHandler) TerminateActivityExecution(
+	ctx context.Context,
+	req *workflowservice.TerminateActivityExecutionRequest,
+) (*workflowservice.TerminateActivityExecutionResponse, error) {
+	namespaceID, err := h.namespaceRegistry.GetNamespaceID(namespace.Name(req.GetNamespace()))
+	if err != nil {
+		return nil, err
+	}
+
+	_, err = h.client.TerminateActivityExecution(ctx, &activitypb.TerminateActivityExecutionRequest{
+		NamespaceId:     namespaceID.String(),
+		FrontendRequest: req,
+	})
+	if err != nil {
+		return nil, err
+	}
+
+	return &workflowservice.TerminateActivityExecutionResponse{}, nil
+}
+
 func (h *frontendHandler) validateAndPopulateStartRequest(
 	req *workflowservice.StartActivityExecutionRequest,
 	namespaceID namespace.ID,