akkoma-fe/src/services/backend_interactor_service/backend_interactor_service.js

import apiService, { getMastodonSocketURI, handleMastoWS } from '../api/api.service.js'
import timelineFetcherService from '../timeline_fetcher/timeline_fetcher.service.js'
import notificationsFetcher from '../notifications_fetcher/notifications_fetcher.service.js'
import followRequestFetcher from '../../services/follow_request_fetcher/follow_request_fetcher.service'

const backendInteractorService = credentials => ({
  startFetchingTimeline ({ timeline, store, userId = false, tag }) {
    return timelineFetcherService.startFetching({ timeline, store, credentials, userId, tag })
  },

  startFetchingNotifications ({ store }) {
    return notificationsFetcher.startFetching({ store, credentials })
  },

  fetchAndUpdateNotifications ({ store }) {
    return notificationsFetcher.fetchAndUpdate({ store, credentials })
  },

  startFetchingFollowRequest ({ store }) {
    return followRequestFetcher.startFetching({ store, credentials })
  },

  startUserSocket ({ store, onMessage }) {
    const serv = store.rootState.instance.server.replace('http', 'ws')
    const url = serv + getMastodonSocketURI({ credentials, stream: 'user' })
    const socket = new WebSocket(url)
    console.debug('Socket created:', socket)
    if (socket) {
      socket.addEventListener('open', (wsEvent) => console.debug('MastoAPI User WebSocket connection established'))
      socket.addEventListener('message', (wsEvent) => onMessage(handleMastoWS(wsEvent)))
      socket.addEventListener('error', (error) => console.error('MastoApi User WebSocket Error:', error))
      return socket
    } else {
      throw new Error('failed to connect to socket')
    }
  },

  ...Object.entries(apiService).reduce((acc, [key, func]) => {
    return {
      ...acc,
      [key]: (args) => func({ credentials, ...args })
    }
  }, {}),

  verifyCredentials: apiService.verifyCredentials
})

export default backendInteractorService