Slack·Teams에서 파일 전송을 실행하고 상태 알림 받기

User
 │
 │ Transfer Request
 ▼
Slack / Teams
 │
 │ Trigger Flow
 ▼
┌─────────────────┐
│  Transfer Flow  │
└────────┬────────┘
         │
         ▼
   File Transfer
         │
    ┌────┴─────┐
    ▼          ▼
 Source      Target
         │
         ▼
 Transfer Result
         │
         ▼
Slack / Teams

Slack / Teams
      │
      ▼
Select Transfer
      │
      ▼
Run Flow
      │
      ▼
File Transfer
      │
 ┌────┴─────┐
 ▼          ▼
Complete    Review
 │          │
 ▼          ▼
Result     Status
      │
      ▼
Slack / Teams

                 Flow 실행
                    │
                    ▼
              ┌───────────┐
              │ Transfer  │
              └─────┬─────┘
                    │
          ┌─────────┼─────────┐
          ▼         ▼         ▼
       Started    Running   Completed
          │         │         │
          └─────────┼─────────┘
                    ▼
              Slack / Teams
                    │
                    ▼
                담당자 확인

┌─────────────────────────────┐
│ Slack / Teams               │
│                             │
│ "일일 보고서 전송 실행"       │
│             │               │
│             ▼               │
│      Flow Started           │
│             │               │
│             ▼               │
│      24 files transferred   │
│      Status: Completed      │
└─────────────────────────────┘

Slack / Teams
      │
      │ Request / Event
      ▼
┌───────────────┐
│ Integration   │
└───────┬───────┘
        ▼
┌───────────────┐
│ Transfer Flow │
└───────┬───────┘
        │
        │ Status / Result
        ▼
Slack / Teams

요청 유형
    │
    ├── Report Transfer ────→ Daily Report Flow
    │
    ├── Backup Archive ────→ Backup Flow
    │
    └── File Distribution ─→ Distribution Flow

Transfer Run
     │
     ├── Started ───────→ 선택적 알림
     │
     ├── Progress ──────→ 필요 시 상태 공유
     │
     ├── Completed ─────→ 완료 알림
     │
     └── Failed ────────→ 즉시 확인 알림

Slack / Teams Notification
           │
           │ Run Result
           ▼
┌────────────────────┐
│ Runs               │
│                    │
│ Flow               │
│ Source             │
│ Target             │
│ Files              │
│ Progress           │
│ Status             │
└────────────────────┘

Failure Alert
      │
      ▼
Run 확인
      │
      ▼
문제 발생 위치 확인
      │
 ┌────┼─────┐
 ▼    ▼     ▼
Source Target 권한
      │
      ▼
환경 조정
      │
      ▼
Retry
      │
      ▼
새 Run 결과
      │
      ▼
Completed Notification

def create_notification(name, webhook_url, channel, kind="slack",
                        events=("started", "completed", "error")):
    result = api("POST", "/api/integrations", {
        "name": name,
        "type": kind,                 # channel type such as slack or teams
        "mode": "webhook",
        "webhookUrl": webhook_url,
        "config": {"name": name, "webhookUrl": webhook_url, "channel": channel},
        # enabled events are notified automatically for every transfer in the workspace
        "notificationConfig": {"events": {e: True for e in events}},
    }) or {}

    return result.get("integrationId")


integration_id = create_notification(
    "transfer-alerts", "https://hooks.slack.com/services/...", "#file-ops")

static String createNotification(InnorixClient client, String name, String webhookUrl,
        String channel, String kind, List<String> events) {
    Map<String, Object> eventMap = Json.newObj();
    for (String e : events) eventMap.put(e, true);   // enabled events are notified automatically across the workspace

    Map<String, Object> result = client.apiObj("POST", "/api/integrations", Json.newObj(
            "name", name,
            "type", kind,             // channel type such as slack or teams
            "mode", "webhook",
            "webhookUrl", webhookUrl,
            "config", Json.newObj("name", name, "webhookUrl", webhookUrl, "channel", channel),
            "notificationConfig", Json.newObj("events", eventMap)), null);

    return Json.str(result, "integrationId");
}

async function createNotification(name, webhookUrl, channel,
                                  kind = "slack", events = ["started", "completed", "error"]) {
  const eventMap = {};
  for (const e of events) eventMap[e] = true;   // enabled events are notified automatically across the workspace

  const result = (await api("POST", "/api/integrations", {
    name,
    type: kind,                 // channel type such as slack or teams
    mode: "webhook",
    webhookUrl,
    config: { name, webhookUrl, channel },
    notificationConfig: { events: eventMap },
  })) || {};

  return result.integrationId;
}

const integrationId = await createNotification(
  "transfer-alerts", "https://hooks.slack.com/services/...", "#file-ops");

static async Task<string> CreateNotificationAsync(InnorixClient client, string name, string webhookUrl,
    string channel, string kind = "slack", IEnumerable<string> events = null)
{
    var eventMap = new JsonObject();
    foreach (var e in events ?? new[] { "started", "completed", "error" })
        eventMap[e] = true;       // enabled events are notified automatically across the workspace

    var result = await client.ApiObjAsync("POST", "/api/integrations", new JsonObject
    {
        ["name"] = name,
        ["type"] = kind,          // channel type such as slack or teams
        ["mode"] = "webhook",
        ["webhookUrl"] = webhookUrl,
        ["config"] = new JsonObject { ["name"] = name, ["webhookUrl"] = webhookUrl, ["channel"] = channel },
        ["notificationConfig"] = new JsonObject { ["events"] = eventMap },
    });

    return J.Str(result, "integrationId");
}

def start_transfer_from_command(source, target, source_paths, target_path,
                                action="numbering"):
    transfer = api("POST", "/api/transfers/manual", {
        "sourceDevice": source,
        "targetDevice": target,
        "targetPath": target_path,
        "sourcePaths": source_paths,
        "sendAllFolder": True,
        "transferOptions": {"target-action": action},
    })

    return transfer["monitorId"]


# call from the slash-command handler
monitor_id = start_transfer_from_command(
    "device-source-01", "device-target-01",
    ["/data/out"], "/work/incoming")

static String startTransferFromCommand(InnorixClient client, String source, String target,
        List<String> sourcePaths, String targetPath, String action) {
    Map<String, Object> transfer = client.apiObj("POST", "/api/transfers/manual", Json.newObj(
            "sourceDevice", source,
            "targetDevice", target,
            "targetPath", targetPath,
            "sourcePaths", sourcePaths,
            "sendAllFolder", true,
            "transferOptions", Json.newObj("target-action", action)), null);

    return Json.str(transfer, "monitorId");
}

async function startTransferFromCommand(source, target, sourcePaths, targetPath,
                                        action = "numbering") {
  const transfer = await api("POST", "/api/transfers/manual", {
    sourceDevice: source,
    targetDevice: target,
    targetPath,
    sourcePaths,
    sendAllFolder: true,
    transferOptions: { "target-action": action },
  });

  return transfer.monitorId;
}

// call from the slash-command handler
const monitorId = await startTransferFromCommand(
  "device-source-01", "device-target-01",
  ["/data/out"], "/work/incoming");

static async Task<string> StartTransferFromCommandAsync(InnorixClient client, string source, string target,
    IEnumerable<string> sourcePaths, string targetPath, string action = "numbering")
{
    var transfer = await client.ApiObjAsync("POST", "/api/transfers/manual", new JsonObject
    {
        ["sourceDevice"] = source,
        ["targetDevice"] = target,
        ["targetPath"] = targetPath,
        ["sourcePaths"] = J.ArrOfStrings(sourcePaths),
        ["sendAllFolder"] = true,
        ["transferOptions"] = new JsonObject { ["target-action"] = action },
    });

    return J.Str(transfer, "monitorId");
}

알림 연동 등록 (1회)
   ↓
채팅 명령 → 전송 시작 (monitorId)
   ↓
전송 이벤트 발생 (started · completed · error)
   ↓
Slack·Teams 채널로 자동 통지