feat: create automations in the current IM chat

Author: debidong

go.mod

@@ -3,7 +3,7 @@ module github.com/flashcatcloud/flashduty-cli
 go 1.26.0
 
 require (
-	github.com/flashcatcloud/go-flashduty v0.15.16
+	github.com/flashcatcloud/go-flashduty v0.15.17-0.20261014102327-2f2d5497df53
 	github.com/mattn/go-runewidth v0.0.30
 	github.com/spf13/cobra v1.10.2
 	github.com/spf13/pflag v1.0.10

go.sum

@@ -1,8 +1,8 @@
 github.com/clipperhouse/uax29/v2 v2.2.0 h1:ChwIKnQN3kcZteTXMgb1wztSgaU+ZemkgWdohwgs8tY=
 github.com/clipperhouse/uax29/v2 v2.2.0/go.mod h1:EFJ2TJMRUaplDxHKj1qAEhCtQPW2tJSwu5BF98AuoVM=
 github.com/cpuguy83/go-md2man/v2 v2.0.6/go.mod h1:oOW0eioCTA6cOiMLiUPZOpcVxMig6NIQQ7OS05n1F4g=
-github.com/flashcatcloud/go-flashduty v0.15.16 h1:h04Z0NGxB4ujlfKliVPD8QhgLgBObeAoRMz9rXJpnes=
-github.com/flashcatcloud/go-flashduty v0.15.16/go.mod h1:YpHiTYXR5NXBI/rGRZfUy537XMkhdCkwA8NW1QoRHwk=
+github.com/flashcatcloud/go-flashduty v0.15.17-0.20261014102327-2f2d5497df53 h1:v6tVZmttBD67/gcdQym1SmY1TavYXd95WU3AQAog9VQ=
+github.com/flashcatcloud/go-flashduty v0.15.17-0.20261014102327-2f2d5497df53/go.mod h1:YpHiTYXR5NXBI/rGRZfUy537XMkhdCkwA8NW1QoRHwk=
 github.com/inconshreveable/mousetrap v1.1.0 h1:wN+x4NVGpMsO7ErUn/mUI3vEoE6Jt13X2s0bqwp9tc8=
 github.com/inconshreveable/mousetrap v1.1.0/go.mod h1:vpF70FUmC8bwa3OWnCshd2FqLfsEA9PFc4w1p2J65bw=
 github.com/mattn/go-runewidth v0.0.30 h1:+KUuiDA4fF0R1p5FeueHefjDm+GIM+kWfFnDjybOPgk=

internal/cli/automation.go

@@ -49,6 +49,7 @@ func newAutomationCreateCmd() *cobra.Command {
 		promptFile      string
 		environmentKind string
 		environmentID   string
+		runIn           string
 		timezone        string
 	)
 
@@ -58,8 +59,14 @@ func newAutomationCreateCmd() *cobra.Command {
 		Long: curatedLong(`Create an AI SRE Automation.
 
 By default the rule is enabled. Use --disabled only when the user explicitly
-asks to create it disabled. team_id=0 means personal scope; --team-id >0 creates
-the rule under that team. The scope is immutable after creation.
+asks to create it disabled. Omit --team-id to let the server inherit the live
+IM conversation scope when available; --team-id 0 explicitly selects personal
+scope and --team-id >0 selects that team. The scope is immutable after creation.
+
+	When this command is invoked from a live IM conversation, omitting --run-in
+lets the server bind the Automation to that current chat. Use --run-in web to
+run it in the web console instead. Do not supply chat, platform, integration,
+or session identifiers: the server resolves and authorizes the current chat.
 
 	Schedule helpers build a 5-field cron expression evaluated in the rule's
 	timezone. Pass --timezone when the user names one. When --timezone is
@@ -86,6 +93,12 @@ the rule under that team. The scope is immutable after creation.
 				if strings.TrimSpace(taskPrompt) == "" {
 					return fmt.Errorf("one of --prompt or --prompt-file is required")
 				}
+				if cmd.Flags().Changed("run-in") {
+					runIn = strings.TrimSpace(runIn)
+					if runIn != "current-chat" && runIn != "web" {
+						return fmt.Errorf("--run-in must be current-chat or web")
+					}
+				}
 
 				effectiveScheduleEnabled := scheduleEnabled
 				cron, err := resolveAutomationCreateCron(cmd, schedule, at, weekday, cronExpr, httpPostTrigger, &effectiveScheduleEnabled)
@@ -95,7 +108,6 @@ the rule under that team. The scope is immutable after creation.
 
 				req := &flashduty.AutomationRuleCreateRequest{
 					Name:                   name,
-					TeamID:                 teamID,
 					CronExpr:               cron,
 					Enabled:                !disabled,
 					ScheduleTriggerEnabled: flashduty.Bool(effectiveScheduleEnabled),
@@ -104,6 +116,12 @@ the rule under that team. The scope is immutable after creation.
 					EnvironmentKind:        strings.TrimSpace(environmentKind),
 					EnvironmentID:          strings.TrimSpace(environmentID),
 				}
+				if cmd.Flags().Changed("team-id") {
+					req.TeamID = flashduty.Int64(teamID)
+				}
+				if cmd.Flags().Changed("run-in") {
+					req.RunIn = flashduty.String(runIn)
+				}
 				if cmd.Flags().Changed("timezone") {
 					req.Timezone = strings.TrimSpace(timezone)
 				}
@@ -117,7 +135,8 @@ the rule under that team. The scope is immutable after creation.
 	}
 
 	cmd.Flags().StringVar(&name, "name", "", "Automation name")
-	cmd.Flags().Int64Var(&teamID, "team-id", 0, "Scope team ID; 0 means personal scope")
+	cmd.Flags().Int64Var(&teamID, "team-id", 0, "Scope team ID; omit to inherit IM scope when available, or pass 0 for personal scope")
+	cmd.Flags().StringVar(&runIn, "run-in", "", "Execution destination: current-chat or web; omit for the server default")
 	cmd.Flags().StringVar(&schedule, "schedule", "", "Schedule helper: hourly, daily, weekly, or cron")
 	cmd.Flags().StringVar(&at, "at", "", "Local time in HH:MM (rule's timezone); for hourly schedules, only the minute is used. "+automationTimezoneNote)
 	cmd.Flags().StringVar(&weekday, "weekday", "", "Weekday for weekly schedules: sun, mon, tue, wed, thu, fri, sat, or 0-7")
@@ -132,6 +151,7 @@ the rule under that team. The scope is immutable after creation.
 	cmd.Flags().StringVar(&environmentID, "environment-id", "", "BYOC Runner ID when --environment-kind=byoc")
 	registerEnumFlag(cmd, "schedule", "hourly", "daily", "weekly", "cron")
 	registerEnumFlag(cmd, "environment-kind", "cloud", "byoc")
+	registerEnumFlag(cmd, "run-in", "current-chat", "web")
 	return cmd
 }
 

internal/cli/automation_test.go

@@ -34,6 +34,65 @@ func TestAutomationCreateDailyDefaultsEnabled(t *testing.T) {
 	assertBody(t, stub.lastBody, "prompt", "Summarize yesterday's incidents")
 }
 
+func TestAutomationCreateExecutionDestinationWireContract(t *testing.T) {
+	t.Run("omits server selected destination", func(t *testing.T) {
+		saveAndResetGlobals(t)
+		stub := newGFStub(t)
+
+		_, err := execCommand(
+			"automation", "create",
+			"--name", "Daily SRE brief",
+			"--prompt", "Summarize yesterday's incidents",
+			"--json",
+		)
+		if err != nil {
+			t.Fatalf("[automation-create-omitted-destination] unexpected error: %v", err)
+		}
+		for _, field := range []string{"run_in", "team_id"} {
+			if _, ok := stub.lastBody[field]; ok {
+				t.Fatalf("[automation-create-omitted-destination] %s must be omitted, body=%#v", field, stub.lastBody)
+			}
+		}
+	})
+
+	t.Run("sends explicit chat and personal scope", func(t *testing.T) {
+		saveAndResetGlobals(t)
+		stub := newGFStub(t)
+
+		_, err := execCommand(
+			"automation", "create",
+			"--name", "Daily SRE brief",
+			"--prompt", "Summarize yesterday's incidents",
+			"--run-in", "current-chat",
+			"--team-id", "0",
+			"--json",
+		)
+		if err != nil {
+			t.Fatalf("[automation-create-current-chat] unexpected error: %v", err)
+		}
+		assertBody(t, stub.lastBody, "run_in", "current-chat")
+		assertBody(t, stub.lastBody, "team_id", float64(0))
+	})
+
+	t.Run("rejects invalid destination before request", func(t *testing.T) {
+		saveAndResetGlobals(t)
+		stub := newGFStub(t)
+
+		_, err := execCommand(
+			"automation", "create",
+			"--name", "Daily SRE brief",
+			"--prompt", "Summarize yesterday's incidents",
+			"--run-in", "other-chat",
+		)
+		if err == nil || !strings.Contains(err.Error(), "--run-in must be current-chat or web") {
+			t.Fatalf("[automation-create-invalid-destination] err = %v", err)
+		}
+		if stub.requests != 0 {
+			t.Fatalf("[automation-create-invalid-destination] request must not reach API, requests=%d", stub.requests)
+		}
+	})
+}
+
 func TestAutomationScheduleHelpDocumentsTimezone(t *testing.T) {
 	saveAndResetGlobals(t)
 
@@ -279,6 +338,18 @@ func TestAutomationUpdateDoesNotExposeScopeFlag(t *testing.T) {
 	}
 }
 
+func TestSafariAutomationRuleUpdateDoesNotExposeExecutionTargetFlags(t *testing.T) {
+	saveAndResetGlobals(t)
+	newGFStub(t)
+
+	for _, flag := range []string{"--team-id", "--run-in"} {
+		_, err := execCommand("safari", "automation-rule-update", "auto_123", flag, "0")
+		if err == nil || !strings.Contains(err.Error(), "unknown flag") {
+			t.Fatalf("[safari-automation-update-target] %s err = %v", flag, err)
+		}
+	}
+}
+
 func TestAutomationFireSendsBearerToken(t *testing.T) {
 	saveAndResetGlobals(t)
 	stub := newGFStub(t)