import type { ActionDefinition } from "../../core/types.ts";

import { s } from "../../core/json-schema.ts";
import { defineProviderAction } from "../../core/provider-definition.ts";

const service = "asana";

const gidField = (description: string) => s.nonEmptyString(description);
const includeFieldsSchema = s.stringArray("Additional Asana fields to request via opt_fields.", {
  minItems: 1,
  itemDescription: "An Asana field name.",
});
const paginationFields = {
  limit: s.integer("Maximum number of items to return in one Asana page.", { minimum: 1, maximum: 100 }),
  cursor: s.nonEmptyString("Opaque pagination cursor returned by a previous Asana response."),
};

const resourceRefSchema = s.looseObject("A compact Asana resource reference.", {
  gid: s.string("The resource gid."),
  resource_type: s.string("The resource type."),
  name: s.string("The resource name."),
});

const workspaceSchema = s.looseObject("An Asana workspace.", {
  gid: s.string("The workspace gid."),
  resource_type: s.string("The resource type."),
  name: s.string("The workspace name."),
  email_domains: s.array("The workspace email domains.", s.string("A workspace email domain.")),
  is_organization: s.boolean("Whether the workspace is an organization."),
});

const projectSchema = s.looseObject("An Asana project.", {
  gid: s.string("The project gid."),
  resource_type: s.string("The resource type."),
  name: s.string("The project name."),
  archived: s.boolean("Whether the project is archived."),
  color: s.nullable(s.string("The project color.")),
  icon: s.nullable(s.string("The project icon.")),
  notes: s.string("The project notes."),
  due_on: s.nullable(s.string("The project due date.")),
  start_on: s.nullable(s.string("The project start date.")),
  default_view: s.string("The project default view."),
  privacy_setting: s.string("The project privacy setting."),
  default_access_level: s.string("The project default access level."),
  created_at: s.string("The project creation timestamp."),
  modified_at: s.string("The project update timestamp."),
  permalink_url: s.string("The project permalink URL."),
  owner: s.nullable(resourceRefSchema),
  workspace: resourceRefSchema,
  team: resourceRefSchema,
  custom_fields: s.array(
    "Custom fields returned by Asana.",
    s.record("A custom field response object.", s.unknown("A custom field value.")),
  ),
});

const taskSchema = s.looseObject("An Asana task.", {
  gid: s.string("The task gid."),
  resource_type: s.string("The resource type."),
  name: s.string("The task name."),
  resource_subtype: s.string("The task subtype."),
  completed: s.boolean("Whether the task is completed."),
  notes: s.string("The task notes."),
  due_on: s.nullable(s.string("The task due date.")),
  due_at: s.nullable(s.string("The task due date-time.")),
  start_on: s.nullable(s.string("The task start date.")),
  start_at: s.nullable(s.string("The task start date-time.")),
  created_at: s.string("The task creation timestamp."),
  modified_at: s.string("The task update timestamp."),
  completed_at: s.nullable(s.string("The task completion timestamp.")),
  permalink_url: s.string("The task permalink URL."),
  approval_status: s.string("The task approval status."),
  assignee: s.nullable(resourceRefSchema),
  workspace: resourceRefSchema,
  parent: s.nullable(resourceRefSchema),
  projects: s.array("Projects linked to the task.", resourceRefSchema),
  memberships: s.array(
    "Memberships returned by Asana.",
    s.record("A task membership object.", s.unknown("A membership value.")),
  ),
  custom_fields: s.array(
    "Custom fields returned by Asana.",
    s.record("A custom field response object.", s.unknown("A custom field value.")),
  ),
});

const nextCursorSchema = s.nullable(
  s.string("Opaque pagination cursor for the next Asana page, or null when there is no next page."),
);

const customFieldsSchema = s.record(
  "Arbitrary object keyed by Asana custom field gid.",
  s.unknown("An Asana custom field value."),
);

const projectMutationFields = {
  name: s.nonEmptyString("The Asana project name."),
  notes: s.string("The Asana project notes."),
  owner: s.nonEmptyString('The project owner identifier, such as "me", an email, or a user gid.'),
  dueOn: s.date("The project due date in YYYY-MM-DD format."),
  startOn: s.date("The project start date in YYYY-MM-DD format."),
  privacySetting: s.string("The Asana project privacy setting."),
  defaultView: s.string("The Asana project default view."),
  defaultAccessLevel: s.string("The Asana project default access level."),
  color: s.string("The Asana project color."),
  icon: s.string("The Asana project icon."),
  customFields: customFieldsSchema,
  archived: s.boolean("Whether the project is archived."),
};

const taskMutationFields = {
  name: s.nonEmptyString("The Asana task name."),
  notes: s.string("The Asana task notes."),
  assignee: s.nonEmptyString('The Asana task assignee, such as "me", an email, or a user gid.'),
  completed: s.boolean("Whether the task is completed."),
  dueOn: s.date("The task due date in YYYY-MM-DD format."),
  dueAt: s.dateTime("The task due date-time in RFC 3339 format."),
  startOn: s.date("The task start date in YYYY-MM-DD format."),
  startAt: s.dateTime("The task start date-time in RFC 3339 format."),
  approvalStatus: s.string("The Asana task approval status."),
  resourceSubtype: s.string("The Asana task subtype."),
  customFields: customFieldsSchema,
};

const createProjectInputSchema = s.object(
  "The input payload for this action.",
  {
    ...projectMutationFields,
    workspaceId: gidField("The Asana workspace gid that owns the project."),
  },
  { required: ["workspaceId", "name"] },
);

const updateProjectInputSchema = s.object(
  "The input payload for this action.",
  {
    ...projectMutationFields,
    projectId: gidField("The Asana project gid."),
  },
  { required: ["projectId"] },
);
updateProjectInputSchema.anyOf = Object.keys(projectMutationFields).map((field) => ({ required: [field] }));

const createTaskInputSchema = s.object(
  "The input payload for this action.",
  {
    ...taskMutationFields,
    projectId: gidField("The Asana project gid that should receive the task."),
  },
  { required: ["projectId", "name"] },
);

const updateTaskInputSchema = s.object(
  "The input payload for this action.",
  {
    ...taskMutationFields,
    taskId: gidField("The Asana task gid."),
  },
  { required: ["taskId"] },
);
updateTaskInputSchema.anyOf = Object.keys(taskMutationFields).map((field) => ({ required: [field] }));

export const asanaActions: ActionDefinition[] = [
  defineProviderAction(service, {
    name: "list_workspaces",
    description: "List the Asana workspaces visible to the connected personal access token.",
    inputSchema: s.object(
      "The input payload for this action.",
      {
        ...paginationFields,
        includeFields: includeFieldsSchema,
      },
      { optional: ["limit", "cursor", "includeFields"] },
    ),
    outputSchema: s.object("The output payload for this action.", {
      workspaces: s.array("The Asana workspaces.", workspaceSchema),
      nextCursor: nextCursorSchema,
    }),
  }),
  defineProviderAction(service, {
    name: "get_workspace",
    description: "Get a single Asana workspace by gid.",
    inputSchema: s.object(
      "The input payload for this action.",
      {
        workspaceId: gidField("The Asana workspace gid."),
        includeFields: includeFieldsSchema,
      },
      { required: ["workspaceId"] },
    ),
    outputSchema: s.object("The output payload for this action.", {
      workspace: workspaceSchema,
    }),
  }),
  defineProviderAction(service, {
    name: "list_projects",
    description: "List Asana projects for a workspace, with optional archived filtering and pagination.",
    inputSchema: s.object(
      "The input payload for this action.",
      {
        workspaceId: gidField("The Asana workspace gid to filter projects on."),
        archived: s.boolean("Whether to include archived projects."),
        ...paginationFields,
        includeFields: includeFieldsSchema,
      },
      { required: ["workspaceId"] },
    ),
    outputSchema: s.object("The output payload for this action.", {
      projects: s.array("The Asana projects.", projectSchema),
      nextCursor: nextCursorSchema,
    }),
  }),
  defineProviderAction(service, {
    name: "get_project",
    description: "Get a single Asana project by gid.",
    inputSchema: s.object(
      "The input payload for this action.",
      {
        projectId: gidField("The Asana project gid."),
        includeFields: includeFieldsSchema,
      },
      { required: ["projectId"] },
    ),
    outputSchema: s.object("The output payload for this action.", {
      project: projectSchema,
    }),
  }),
  defineProviderAction(service, {
    name: "create_project",
    description: "Create an Asana project in a workspace with optional notes, owner, dates, and display settings.",
    inputSchema: createProjectInputSchema,
    outputSchema: s.object("The output payload for this action.", {
      project: projectSchema,
    }),
  }),
  defineProviderAction(service, {
    name: "update_project",
    description: "Update an existing Asana project by gid.",
    inputSchema: updateProjectInputSchema,
    outputSchema: s.object("The output payload for this action.", {
      project: projectSchema,
    }),
  }),
  defineProviderAction(service, {
    name: "list_project_tasks",
    description: "List tasks within an Asana project, ordered by project priority, with pagination support.",
    inputSchema: s.object(
      "The input payload for this action.",
      {
        projectId: gidField("The Asana project gid."),
        completedSince: s.anyOf(
          'Only include tasks incomplete or completed since this RFC 3339 timestamp, or use the literal "now".',
          [s.literal("now"), s.dateTime("A completion timestamp.")],
        ),
        ...paginationFields,
        includeFields: includeFieldsSchema,
      },
      { required: ["projectId"] },
    ),
    outputSchema: s.object("The output payload for this action.", {
      tasks: s.array("The Asana tasks.", taskSchema),
      nextCursor: nextCursorSchema,
    }),
  }),
  defineProviderAction(service, {
    name: "get_task",
    description: "Get a single Asana task by gid.",
    inputSchema: s.object(
      "The input payload for this action.",
      {
        taskId: gidField("The Asana task gid."),
        includeFields: includeFieldsSchema,
      },
      { required: ["taskId"] },
    ),
    outputSchema: s.object("The output payload for this action.", {
      task: taskSchema,
    }),
  }),
  defineProviderAction(service, {
    name: "create_task",
    description: "Create a new Asana task in a project with optional assignee, notes, dates, and custom fields.",
    inputSchema: createTaskInputSchema,
    outputSchema: s.object("The output payload for this action.", {
      task: taskSchema,
    }),
  }),
  defineProviderAction(service, {
    name: "update_task",
    description: "Update an existing Asana task by gid.",
    inputSchema: updateTaskInputSchema,
    outputSchema: s.object("The output payload for this action.", {
      task: taskSchema,
    }),
  }),
];