@kody/asana

import { asanaRequest } from './client.ts'
import { mapTask, TASK_FIELDS } from './models.ts'
import type {
	AsanaAuthInput,
	AsanaTaskSummary,
	DryRunResult,
	JsonRecord,
} from './types.ts'
import {
	compactRecord,
	optionalBoolean,
	optionalString,
	optionalStringArray,
	requireRecord,
	requireString,
} from './types.ts'
import { requireAuthMode } from './auth.ts'

export type CreateTaskInput = AsanaAuthInput & {
	name: string
	/** Workspace GID. Required unless `projects` is set. */
	workspaceGid?: string
	/** Project GIDs to add the task to. */
	projects?: Array<string>
	notes?: string
	assignee?: string
	dueOn?: string
	dueAt?: string
	completed?: boolean
	parentGid?: string
	confirm?: boolean
	dryRun?: boolean
}

function taskCreatePayload(input: CreateTaskInput): JsonRecord {
	const payload = compactRecord({
		name: requireString(input.name, 'name'),
		workspace: optionalString(input.workspaceGid, 'workspaceGid'),
		projects: optionalStringArray(input.projects, 'projects'),
		notes: optionalString(input.notes, 'notes'),
		assignee: optionalString(input.assignee, 'assignee'),
		due_on: optionalString(input.dueOn, 'dueOn'),
		due_at: optionalString(input.dueAt, 'dueAt'),
		completed: optionalBoolean(input.completed, 'completed'),
		parent: optionalString(input.parentGid, 'parentGid'),
	})
	if (!payload.workspace && !(Array.isArray(payload.projects) && payload.projects.length > 0)) {
		throw new Error('create-task requires workspaceGid or at least one project GID.')
	}
	return payload
}

/**
 * Create an Asana task. Requires `confirm: true`, or use `dryRun: true`.
 * Needs `tasks:write`.
 * @example
 * import createTask from 'kody:@kody/asana/create-task'
 * const preview = await createTask({
 *   name: 'Follow up on onboarding',
 *   workspaceGid: '123',
 *   dryRun: true,
 * })
 */
export async function createTask(
	input: CreateTaskInput,
): Promise<AsanaTaskSummary | DryRunResult<{ method: string; path: string; data: JsonRecord }>> {
	const payload = taskCreatePayload(input)
	if (input.dryRun) {
		return { dryRun: true, wouldCall: { method: 'POST', path: '/tasks', data: payload } }
	}
	if (input.confirm !== true) {
		throw new Error(
			'Creating an Asana task requires confirm: true after explicit user approval, or dryRun: true.',
		)
	}

	const result = await asanaRequest<unknown>({
		...input,
		operation: 'tasks.write',
		method: 'POST',
		path: '/tasks',
		query: { opt_fields: TASK_FIELDS },
		body: payload,
	})
	if (!result.data) throw new Error('Asana create task did not return a task.')
	return mapTask(result.data)
}

/**
 * Create an Asana task. Requires `confirm: true`, or use `dryRun: true`.
 * @example
 * import createTask from 'kody:@kody/asana/create-task'
 * const preview = await createTask({ name: 'Bug', workspaceGid: '123', dryRun: true })
 */
export default async function createTaskEntrypoint(
	params: Partial<CreateTaskInput> & Record<string, unknown> = {},
) {
	const input = requireRecord(params, 'create-task')
	return createTask({
		name: requireString(input.name, 'name'),
		workspaceGid: optionalString(input.workspaceGid, 'workspaceGid'),
		projects: optionalStringArray(input.projects, 'projects'),
		notes: optionalString(input.notes, 'notes'),
		assignee: optionalString(input.assignee, 'assignee'),
		dueOn: optionalString(input.dueOn, 'dueOn'),
		dueAt: optionalString(input.dueAt, 'dueAt'),
		completed: optionalBoolean(input.completed, 'completed'),
		parentGid: optionalString(input.parentGid, 'parentGid'),
		integrationName: optionalString(input.integrationName, 'integrationName'),
		integration: optionalString(input.integration, 'integration'),
		account: optionalString(input.account, 'account'),
		secretName: optionalString(input.secretName, 'secretName'),
		auth: requireAuthMode(input.auth),
		confirm: optionalBoolean(input.confirm, 'confirm'),
		dryRun: optionalBoolean(input.dryRun, 'dryRun'),
	})
}