/**
 * Copyright 2022 Gravwell, Inc. All rights reserved.
 *
 * Contact: [legal@gravwell.io](mailto:legal@gravwell.io)
 *
 * This software may be modified and distributed under the terms of the MIT
 * license. See the LICENSE file for details.
 */

import { BehaviorSubject, Observable } from 'rxjs';
import { Notification } from '~/models/notification/notification';
import { APIContext } from '../utils/api-context';
import { APISubscription } from '../utils/api-subscription';
import { makeGetMyNotifications } from './get-my-notifications';

export type MyNotificationsMessageReceived = Array<Notification>;

export type MyNotificationsMessageSent = never;

export const makeSubscribeToMyNotifications = (
	context: APIContext,
): ((options?: {
	pollInterval?: number | undefined;
}) => Promise<APISubscription<MyNotificationsMessageReceived, MyNotificationsMessageSent>>) => {
	const getMyNotifications = makeGetMyNotifications(context);

	return async (
		options: { pollInterval?: number | undefined } = { pollInterval: 10000 },
	): Promise<APISubscription<MyNotificationsMessageReceived, MyNotificationsMessageSent>> => {
		const pollInterval = options.pollInterval ?? 10000;

		let timeoutID: ReturnType<typeof setTimeout>;
		const setPoll = (): void => {
			timeoutID = setTimeout(async () => {
				const notifications = await getMyNotifications();
				_received$.next(notifications);
				setPoll();
			}, pollInterval);
		};

		const firstNotifications = await getMyNotifications();
		setPoll();

		const received: Array<MyNotificationsMessageReceived> = [];
		const _received$ = new BehaviorSubject<MyNotificationsMessageReceived>(firstNotifications);
		_received$.subscribe({ next: receivedMessage => received.push(receivedMessage), error: err => console.warn(err) });

		return {
			send: async () => undefined,
			close: () => clearTimeout(timeoutID),
			received,
			received$: _received$.asObservable(),
			sent: [],
			sent$: new Observable<MyNotificationsMessageSent>(),
		};
	};
};