io-ts + slonik

iots-slonik.ts

import {
    TaggedTemplateLiteralInvocationType,
    QueryResultRowType,
    DatabasePoolType
} from 'slonik'
import * as t from 'io-ts'
import { Either } from 'fp-ts/Either'

const query = async <T>(
    sqlQuery: TaggedTemplateLiteralInvocationType<QueryResultRowType>,
    decoder: t.Type<T>,
    pool: DatabasePoolType
) : Promise<Either<t.Errors, T[]>> => {
    const result = await pool.query(sqlQuery)

    return t.array(decoder).decode(result.rows)
}