backend-id: bootstrap

Author: orlowdev

lib/_tau/src/impl.ts

@@ -70,14 +70,6 @@ export const lte = (max: number) => (val: number) => eq(max)(val) || lt(max)(val
 export const noop = (): void => {}
 export const undef = (): undefined => {}
 
-export const is_port = (x: string) => {
-	const n = Number.parseInt(x, 10)
-	const gt_0 = gt(0)
-	const lt_65535 = lt(65535)
-
-	return !x.startsWith("0") && !is_nan(n) && gt_0(n) && lt_65535(n)
-}
-
 export const keys_of: <T extends object>(o: T) => (keyof T)[] = o => {
 	return Object.keys(o) as any
 }

lib/b-email-strategy-rusender/src/b-email-strategy-rusender.constants.ts

@@ -22,7 +22,7 @@
 export const URL = "https://api.beta.rusender.ru/api/v1/external-mails/send"
 export const METHOD = "POST"
 
-export const X_API_KEY_HEADER_KEY = "x-api-key"
+export const X_API_KEY_HEADER_KEY = "X-Api-Key"
 
 // TODO Move out
-export const CONTENT_TYPE_HEADER = ["content-type", "application/json"] as const
+export const CONTENT_TYPE_HEADER = ["Content-Type", "application/json"] as const

lib/b-email-strategy-rusender/src/b-email-strategy-rusender.impl.ts

@@ -22,10 +22,10 @@
 import { type Oath, oath } from "@ordo-pink/oss-oath"
 import { core } from "@ordo-pink/sdk-core"
 
-import * as CONST from "./b-email-strategy-rusender.constants"
-import type * as Types from "./b-email-strategy-rusender.types"
+import * as LIB from "./b-email-strategy-rusender.constants"
+import type * as Lib from "./b-email-strategy-rusender.types"
 
-export const create: Types.Create = (k, s) => ({
+export const create: Lib.Create = (k, s) => ({
 	send: (idempotencyKey, subject, html, to, from = s, previewTitle, headers, cc, bcc) =>
 		oath
 			.all([to_json({ idempotencyKey, mail: { bcc, cc, from, headers, html, previewTitle, subject, to } }), create_headers(k)])
@@ -42,12 +42,12 @@ const ignore_response = core.fns.v
 
 type SendRequest = (args: [string, Headers]) => Oath.Instance<Response, Error>
 const send_request: SendRequest = ([body, headers]) =>
-	oath.from_promise(() => fetch(CONST.URL, { method: CONST.METHOD, body, headers }))
+	oath.from_promise(() => fetch(LIB.URL, { method: LIB.METHOD, body, headers }))
 
-const create_headers = (k: Types.ApiKey) =>
+const create_headers = (k: Lib.ApiKey) =>
 	oath
 		.of(new Headers())
-		.pipe(oath.ops.tap(h => h.set(...CONST.CONTENT_TYPE_HEADER)))
+		.pipe(oath.ops.tap(h => h.set(...LIB.CONTENT_TYPE_HEADER)))
 		.pipe(oath.ops.tap(h => h.set(...create_api_key_header(k))))
 
-const create_api_key_header = (k: Types.ApiKey) => [CONST.X_API_KEY_HEADER_KEY, k] as const
+const create_api_key_header = (k: Lib.ApiKey) => [LIB.X_API_KEY_HEADER_KEY, k] as const

lib/b-email-strategy-rusender/src/b-email-strategy-rusender.types.ts

@@ -19,14 +19,15 @@
  * along with this program.  If not, see <https://www.gnu.org/licenses/>.
  */
 
-import type * as EMAIL_STRATEGY_RUSENDER from "./b-email-strategy-rusender.constants"
 import type { Server } from "@ordo-pink/sdk-server"
 
+import type * as LIB from "./b-email-strategy-rusender.constants"
+
 export type ApiKey = string
 export type From = Server.Email.EmailGuy
 export type Args = [api_key: ApiKey, sender: From]
 export type Instance = Server.Email.Strategy
 
 export type Create = (...args: Args) => Instance
 
-export type CreateApiKeyHeader = (key: ApiKey) => [typeof EMAIL_STRATEGY_RUSENDER.X_API_KEY_HEADER_KEY, ApiKey]
+export type CreateApiKeyHeader = (key: ApiKey) => [typeof LIB.X_API_KEY_HEADER_KEY, ApiKey]

lib/b-repository-data-fs/src/b-repository-data-fs.impl.ts

@@ -30,9 +30,9 @@ import { resolve } from "path"
 import { type Core, core } from "@ordo-pink/sdk-core"
 import { oath } from "@ordo-pink/oss-oath"
 
-import * as Types from "./b-repository-data-fs.types"
+import type * as Lib from "./b-repository-data-fs.types"
 
-export const create: Types.Create = root => {
+export const create: Lib.Create = root => {
 	const get_path = get_path_from_root(root)
 
 	return {
@@ -65,8 +65,8 @@ export const create: Types.Create = root => {
 
 // --- Internal ---
 
-const to_already_exists_rrr = () => core.rrr.eexist("File already exists")
-const to_not_found_rrr = () => core.rrr.enoent("File not found")
+const to_already_exists_rrr = () => core.rrr.eexist("File already exists", null)
+const to_not_found_rrr = () => core.rrr.enoent("File not found", null)
 const to_io_rrr = (e: unknown) => core.rrr.eio("Failed to store local data", e)
 
 const get_file = (path: string) => oath.try(() => Bun.file(path)).pipe(oath.ops.rmap(to_io_rrr))

lib/b-repository-data-s3/src/b-repository-data-s3.impl.ts

@@ -24,9 +24,9 @@ import { S3Client, S3File } from "bun"
 import { type Core, core } from "@ordo-pink/sdk-core"
 import { oath } from "@ordo-pink/oss-oath"
 
-import type * as Types from "./b-repository-data-s3.types"
+import type * as Lib from "./b-repository-data-s3.types"
 
-export const create: Types.Create = (accessKeyId, secretAccessKey, region, bucket, endpoint) => {
+export const create: Lib.Create = (accessKeyId, secretAccessKey, region, bucket, endpoint) => {
 	const s3 = new Bun.S3Client({ accessKeyId, bucket, endpoint, region, secretAccessKey })
 
 	return {
@@ -60,8 +60,8 @@ export const create: Types.Create = (accessKeyId, secretAccessKey, region, bucke
 
 // --- Internal ---
 
-const already_exists_rrr = () => core.rrr.eexist("File already exists")
-const not_found_rrr = () => core.rrr.enoent("File not found")
+const already_exists_rrr = () => core.rrr.eexist("File already exists", null)
+const not_found_rrr = () => core.rrr.enoent("File not found", null)
 const io_rrr = (e: unknown) => core.rrr.eio("Failed to connect to S3", e)
 
 const get_file = (s3: S3Client) => (path: string) =>

lib/b-repository-user-repository-data/src/b-repository-user-repository-data.impl.ts

@@ -23,16 +23,16 @@ import { type Core, core } from "@ordo-pink/sdk-core"
 import { type Server, server } from "@ordo-pink/sdk-server"
 import { oath } from "@ordo-pink/oss-oath"
 
-import * as Types from "./b-repository-user-repository-data.types"
+import type * as Lib from "./b-repository-user-repository-data.types"
 
-export const create: Types.Create = (repository, uid, fid, ufid) => {
+export const create: Lib.Create = (repository, uid, fid, ufid) => {
 	let cache = get_cache_promise(repository, uid, fid)
-	const cache0 = oath.from_promise<Types.Cache, never>(() => cache)
+	const cache0 = oath.from_promise<Lib.Cache, never>(() => cache)
 
-	const read: Types.Instance["read"] = id =>
-		repository.read(id, ufid).pipe(oath.ops.chain(from_stream0(() => core.rrr.eio("Cound not read user"))))
+	const read: Lib.Instance["read"] = id =>
+		repository.read(id, ufid).pipe(oath.ops.chain(from_stream0(() => core.rrr.eio("Cound not read user", id))))
 
-	const update_cache0 = (current_cache: Types.Cache) =>
+	const update_cache0 = (current_cache: Lib.Cache) =>
 		oath
 			.try(() => JSON.stringify(current_cache))
 			.pipe(oath.ops.chain(to_stream0()))
@@ -70,7 +70,7 @@ export const create: Types.Create = (repository, uid, fid, ufid) => {
 
 		read,
 
-		delete: id => repository.delete(id),
+		delete: repository.delete,
 
 		update: (id, new_user) =>
 			read(id).pipe(
@@ -135,8 +135,8 @@ const to_rrr = (message: string) => (error: unknown) => core.rrr.eio(message, er
 const get_cache_promise = (repository: Server.Data.Repository, uid: Core.User.Id, fid: Core.Data.Id) =>
 	repository
 		.read(uid, fid)
-		.pipe(oath.ops.chain(stream => oath.from_promise(() => Bun.readableStreamToJSON(stream) as Promise<Types.Cache>)))
-		.cata(oath.catas.or_else(() => ({ email: {}, ref: {} }) as Types.Cache))
+		.pipe(oath.ops.chain(stream => oath.from_promise(() => Bun.readableStreamToJSON(stream) as Promise<Lib.Cache>)))
+		.cata(oath.catas.or_else(() => ({ email: {}, ref: {} }) as Lib.Cache))
 
 const to_stream0 =
 	<$F>(on_error: (e: unknown) => $F = e => e as any) =>

lib/b-repository-user-repository-data/src/b-repository-user-repository-data.test.ts

@@ -23,7 +23,7 @@ import type { Core } from "@ordo-pink/sdk-core"
 import type { Server } from "@ordo-pink/sdk-server"
 
 export type Args = [
-	repository_data: Server.Data.Repository,
+	data_repository: Server.Data.Repository,
 	cache_user_id: Core.User.Id,
 	cache_file_id: Core.Data.Id,
 	user_file_id: Core.Data.Id,

lib/b-repository-user-repository-data/src/b-repository-user-repository-data.types.ts

@@ -0,0 +1,23 @@
+/*
+ * SPDX-FileCopyrightText: Copyright 2025, 谢尔盖 ||↓ and the Ordo.pink contributors
+ * SPDX-License-Identifier: AGPL-3.0-only
+ *
+ * Ordo.pink is an all-in-one team workspace.
+ * Copyright (C) 2025  谢尔盖 ||↓ and the Ordo.pink contributors
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as published
+ * by the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program.  If not, see <https://www.gnu.org/licenses/>.
+ */
+
+export * as server_id from "./src/b-server-id.impl"
+export * as ServerId from "./src/b-server-id.types"