app/services/data/entityManager.ts

import ApiRequestService from "./apiRequestService";
import {Repository, useRepo} from "pinia-orm";
import Url from "~/services/utils/url";
import ModelNormalizer from "./serializer/normalizer/modelNormalizer";
import HydraDenormalizer from "./serializer/denormalizer/hydraDenormalizer";
import ApiModel from "~/models/ApiModel";
import ApiResource from "~/models/ApiResource";
import {MyProfile} from "~/models/Access/MyProfile";
import {v4 as uuid4} from 'uuid';
import {AssociativeArray, Collection} from "~/types/data.d";
import {useCloneDeep} from "#imports";
import models from "~/models/models";
import {useAccessProfileStore} from "~/stores/accessProfile";

/**
 * Entity manager: make operations on the models defined with the Pinia-Orm library
 *
 * @see https://pinia-orm.codedredd.de/
 */
class EntityManager {
    private CLONE_PREFIX = '_clone_'

    private apiRequestService: ApiRequestService

    public constructor(
        apiRequestService: ApiRequestService
    ) {
        this.apiRequestService = apiRequestService
    }

    /**
     * Return the repository for the model
     *
     * @param model
     */
    public getRepository(model: typeof ApiResource): Repository<ApiResource> {
        return useRepo(model)
    }

    // noinspection JSMethodCanBeStatic
    public cast(model: typeof ApiResource, entity: ApiResource): ApiResource {
        return new model(entity)
    }

    /**
     * Return the model class with the given entity name
     *
     * @param entityName
     */
    public getModelFor(entityName: string): typeof ApiResource {
        return models[entityName]
    }

    /**
     * Return the model class from an Opentalent Api IRI
     *
     * @param iri An IRI of the form .../api/<entity>/...
     */
    public getModelFromIri(iri: string): typeof ApiResource {
        const matches = iri.match(/^\/api\/(\w+)\/.*/)
        if (!matches || !matches[1]) {
            throw new Error('cannot parse the IRI')
        }
        return this.getModelFor(matches[1])
    }

    /**
     * Create a new instance of the given model
     *
     * @param model
     * @param properties
     */
    public newInstance(model: typeof ApiResource, properties: object = {}): ApiResource {
        const repository = this.getRepository(model)

        let entity = repository.make(properties)

        // Keep track of the entitie's model
        entity.setModel(model)

        // @ts-ignore
        if (!properties.hasOwnProperty('id') || !properties.id) {
            // Object has no id yet, we give him a temporary one
            entity.id = 'tmp' + uuid4()
        }

        entity = repository.save(entity)

        this.saveInitialState(model, entity)
        return entity
    }

    /**
     * Save the entity into the store
     *
     * @param model
     * @param entity
     */
    public save(model: typeof ApiResource, entity: ApiResource): ApiResource {
        return this.getRepository(model).save(entity)
    }


    /**
     * Find the entity into the store
     *
     * @param model
     * @param id
     */
    // @ts-ignore
    public find<T extends ApiResource>(model: typeof T, id: number): T {
        const repository = this.getRepository(model)
        return repository.find(id) as T
    }

    /**
     * Fetch an Entity / ApiResource by its id, save it to the store and returns it
     *
     * @param model  Model of the object to fetch
     * @param id   Id of the object to fetch
     * @param forceRefresh  Force a new get request to the api ;
     *                      current object in store will be overwritten if it exists
     */
    public async fetch(model: typeof ApiResource, id: number, forceRefresh: boolean = false): Promise<ApiResource> {

        const repository = this.getRepository(model)

        // If the entity is already in the store and forceRefresh is false, return the object in store
        if (!forceRefresh) {
            const item = repository.find(id)
            if (item && typeof item !== 'undefined') {
                return item
            }
        }

        // Else, get the object from the API
        const url = Url.join('api', model.entity, String(id))

        const response = await this.apiRequestService.get(url)

        // deserialize the response
        const attributes = HydraDenormalizer.denormalize(response).data as object

        return this.newInstance(model, attributes)
    }

    /**
     * Fetch a collection of entity
     * The content of `query` is converted into a query-string in the request URL
     *
     * @param model
     * @param query
     * @param parent
     */
    public async fetchCollection(model: typeof ApiResource, parent: ApiResource | null, query: AssociativeArray = []): Promise<Collection> {
        let url
        if (parent !== null) {
            url = Url.join('api', parent.entity, '' + parent.id, model.entity)
        } else {
            url = Url.join('api', model.entity)
        }

        const response = await this.apiRequestService.get(url, query)

        // deserialize the response
        const apiCollection = HydraDenormalizer.denormalize(response)

        const items = apiCollection.data.map((attributes: object) => {
            return this.newInstance(model, attributes)
        })

        return {
            items,
            totalItems: apiCollection.metadata.totalItems,
            pagination: {
                first: apiCollection.metadata.firstPage || 1,
                last: apiCollection.metadata.lastPage || 1,
                next: apiCollection.metadata.nextPage || undefined,
                previous: apiCollection.metadata.previousPage || undefined,
            }
        }
    }

    private async saveResponseAsEntity(model: typeof ApiModel, response: Response) {
        const repository = this.getRepository(model)

        const hydraResponse = await HydraDenormalizer.denormalize(response)
        const returnedEntity = this.newInstance(model, hydraResponse.data)

        this.saveInitialState(model, returnedEntity)

        // Save data into the store
        repository.save(returnedEntity)

        return returnedEntity
    }

    /**
     * Persist the entity as it is in the store into the data source via the API
     *
     * @param model
     * @param entity
     */
    public async persist(model: typeof ApiModel, entity: ApiModel) {
        // Recast in case class definition has been "lost"
        entity = this.cast(model, entity)

        let url = Url.join('api', model.entity)
        let response

        const data = ModelNormalizer.normalize(entity)

        if (!entity.isNew()) {
            url = Url.join(url, String(entity.id))
            response = await this.apiRequestService.put(url, data)
        } else {
            delete data.id
            response = await this.apiRequestService.post(url, data)
        }

        const createdEntity = this.saveResponseAsEntity(model, response)

        if (entity.isNew()) {
            this.removeTempAfterPersist(model, entity.id)
        }

        return createdEntity
    }

    /**
     * Send an update request (PUT) to the API with the given data on an existing entity
     *
     * @param model
     * @param id
     * @param data
     */
    public async patch(model: typeof ApiModel, id: number, data: AssociativeArray) {
        let url = Url.join('api', model.entity, ''+id)

        const body = JSON.stringify(data)
        const response = await this.apiRequestService.put(url, body)

        return this.saveResponseAsEntity(model, response)
    }

    /**
     * Delete the entity from the datasource via the API
     *
     * @param model
     * @param entity
     */
    public async delete(model: typeof ApiModel, entity: ApiResource) {
        const repository = this.getRepository(model)

        // If object has been persisted to the datasource, send a delete request
        if (!entity.isNew()) {
            const url = Url.join('api', model.entity, String(entity.id))
            await this.apiRequestService.delete(url)
        }

        // reactiveUpdate the store
        repository.destroy(entity.id)
    }

    /**
     * Reset the entity to its initial state (i.e. the state it had when it was fetched from the API)
     *
     * @param model
     * @param entity
     */
    public reset(model: typeof ApiResource, entity: ApiResource) {
        const initialEntity = this.getInitialStateOf(model, entity.id)
        if (initialEntity === null) {
            throw new Error('no initial state recorded for this object - abort [' + model.entity + '/' + entity.id + ']')
        }

        const repository = this.getRepository(model)
        repository.save(initialEntity)

        return initialEntity
    }

    /**
     * @Deprecated : a priori ce n'est pas le bon service pour mettre à jour le profil, on devrait voir ça
     * depuis un service dédié, un composable, ou directement dans le store
     *
     * Re-fetch the user profile and update the store
     */
    public async refreshProfile(accessId: number) {
        const profile = await this.fetch(MyProfile, accessId)

        // On met à jour le store accessProfile
        const accessProfileStore = useAccessProfileStore()
        accessProfileStore.setProfile(profile)
    }

    /**
     * Delete all records in the repository of the model
     *
     * @param model
     */
    public async flush(model: typeof ApiModel) {
        const repository = this.getRepository(model)
        repository.flush()
    }

    /**
     * Is the entity a new one, or does it already exist in the data source (=API)
     *
     * @param model
     * @param id
     */
    public isNewEntity(model: typeof ApiModel, id: number | string): boolean {
        const repository = this.getRepository(model)

        const item = repository.find(id)
        if (!item || typeof item === 'undefined') {
            console.error(model.entity + '/' + id, ' does not exist!')
            return false
        }

        return item.isNew()
    }

    /**
     * Save the state of the entity in the store, so this state could be be restored later
     *
     * @param model
     * @param entity
     * @private
     */
    private saveInitialState(model: typeof ApiResource, entity: ApiResource) {
        const repository = this.getRepository(model)

        // Clone and prefix id
        const clone = useCloneDeep(entity)
        clone.id = this.CLONE_PREFIX + clone.id

        repository.save(clone)
    }

    /**
     * Return the saved state of the entity from the store
     *
     * @param model
     * @param id
     * @private
     */
    private getInitialStateOf(model: typeof ApiResource, id: string | number): ApiResource | null {
        const repository = this.getRepository(model)

        // Find the clone by id
        const entity = repository.find(this.CLONE_PREFIX + id)
        if (entity === null) {
            return null
        }

        // Restore the initial id
        entity.id = id
        return entity
    }

    /**
     * Delete the temporary entity from the repo after it was persisted via the api, replaced by the entity
     * that has been returned by the api with is definitive id.
     *
     * @param model
     * @param tempEntityId
     * @private
     */
    private removeTempAfterPersist(model: typeof ApiResource, tempEntityId: number) {
        const repository = this.getRepository(model)

        const entity = repository.find(tempEntityId)
        if (!entity || typeof entity === 'undefined') {
            console.error(model.entity + '/' + tempEntityId, ' does not exist!')
            return
        }
        if (!entity.isNew()) {
            throw new Error('Error: Can not remove a non-temporary entity')
        }

        repository.destroy(tempEntityId)
        repository.destroy(this.CLONE_PREFIX + tempEntityId)
    }
}

export default EntityManager