import { Context, Service, ServiceBroker, ServiceSchema, Errors } from "moleculer";
import axios from "axios";

export default class ProwlarrService extends Service {
	// @ts-ignore
	constructor(
		public broker: ServiceBroker,
		schema: ServiceSchema<{}> = { name: "prowlarr" },
	) {
		super(broker);
		this.parseServiceSchema({
			name: "prowlarr",
			mixins: [],
			hooks: {},
			actions: {
				connect: {
					rest: "POST /connect",
					handler: async (
						ctx: Context<{
							host: string;
							port: string;
							apiKey: string;
						}>,
					) => {
						const { host, port, apiKey } = ctx.params;
						const result = await axios.request({
							url: `http://${host}:${port}/api`,
							method: "GET",
							headers: {
								"X-Api-Key": apiKey,
							},
						});
						console.log(result.data);
					},
				},
				getIndexers: {
					rest: "GET /indexers",
					handler: async (
						ctx: Context<{ host: string; port: string; apiKey: string }>,
					) => {
						const { host, port, apiKey } = ctx.params;
						const result = await axios.request({
							url: `http://${host}:${port}/api/v1/indexer`,
							method: "GET",
							headers: {
								"X-Api-Key": apiKey,
							},
						});
						return result.data;
					},
				},
				search: {
					rest: "GET /search",
					handler: async (
						ctx: Context<{
							prowlarrQuery: {
								host: string;
								port: string;
								apiKey: string;
								query: string;
								type: string;
								indexerIds: [number];
								categories: [number];
								limit: number;
								offset: number;
							};
						}>,
					) => {
						const {
							prowlarrQuery: {
								indexerIds,
								categories,
								host,
								port,
								apiKey,
								query,
								type,
								limit,
								offset,
							},
						} = ctx.params;
						const indexer = indexerIds[0] ? indexerIds.length === 1 : indexerIds;
						const category = categories[0] ? categories.length === 1 : categories;
						const result = await axios({
							url: `http://${host}:${port}/api/v1/search`,
							method: "GET",
							params: {
								query,
								type,
								indexer,
								category,
								limit,
								offset,
							},
							headers: {
								Accept: "application/json",
								"X-Api-Key": `${apiKey}`,
							},
						});
						return result.data;
					},
				},
				ping: {
					rest: "GET /ping",
					handler: async (ctx: Context<{}>) => {
						const foo = await axios.request({
							url: "http://192.168.1.183:9696/ping",
							method: "GET",
							headers: {
								Accept: "application/json",
								"X-Api-Key": "163ef9a683874f65b53c7be87354b38b",
							},
						});
						console.log(foo.data);
						return true;
					},
				},
			},
			methods: {},
		});
	}
}