import { RxCollection, RxDocument, RxJsonSchema } from 'rxdb'
import { MetaverseLightwalletDatabase } from './database'
import { Observable } from 'rxjs'
import { map } from 'rxjs/operators'

export interface Address {
    address: string
    path: string
}


export async function initAddressCollection(database: MetaverseLightwalletDatabase): Promise<AddressCollection> {
    const addressCollection = await database.collection<Address, AddressDocMethods, AddressCollectionMethods>({
        name: 'addresses',
        schema: addressSchema,
        methods: {},
        statics: addressCollectionMethods,
    })
    return addressCollection
}

export type AddressDocMethods = {}

export type AddressDocument = RxDocument<Address, AddressDocMethods>

export type AddressCollection = RxCollection<Address, AddressDocMethods, AddressCollectionMethods>

export type AddressCollectionMethods = {
    addresses$: () => Observable<string[]>
}

export const addressCollectionMethods: AddressCollectionMethods = {
    addresses$: function (this: AddressCollection) {
        return this.find().$.pipe(map(addresses => {
            return addresses.map(address => address.get('address'))
        }))
    }
}

export const addressSchema: RxJsonSchema<Address> = {
    title: 'address',
    version: 0,
    description: 'Metaverse Addresses',
    type: 'object',
    properties: {
        address: {
            type: 'string',
            primary: true,
        },
        path: {
            "type": "string",
        },

    },
}