@atproto/bsync
Advanced tools
Comparing version 0.0.0 to 0.0.1
import { Interceptor, PromiseClient } from '@connectrpc/connect'; | ||
import { ConnectTransportOptions } from '@connectrpc/connect-node'; | ||
import { Service } from './gen/bsync_connect'; | ||
import { Service } from './proto/bsync_connect'; | ||
export type BsyncClient = PromiseClient<typeof Service>; | ||
export declare const createClient: (opts: ConnectTransportOptions) => BsyncClient; | ||
export declare const authWithApiKey: (apiKey: string) => Interceptor; |
import { GeneratedAlways, Selectable } from 'kysely'; | ||
import { MuteOperation_Type } from '../../gen/bsync_pb'; | ||
import { MuteOperation_Type } from '../../proto/bsync_pb'; | ||
export interface MuteOp { | ||
@@ -4,0 +4,0 @@ id: GeneratedAlways<number>; |
import { ServiceImpl } from '@connectrpc/connect'; | ||
import { Service } from '../gen/bsync_connect'; | ||
import { Service } from '../proto/bsync_connect'; | ||
import AppContext from '../context'; | ||
declare const _default: (ctx: AppContext) => Partial<ServiceImpl<typeof Service>>; | ||
export default _default; |
import { ServiceImpl } from '@connectrpc/connect'; | ||
import { Service } from '../gen/bsync_connect'; | ||
import { Service } from '../proto/bsync_connect'; | ||
import AppContext from '../context'; | ||
declare const _default: (ctx: AppContext) => Partial<ServiceImpl<typeof Service>>; | ||
export default _default; |
Dual MIT/Apache-2.0 License | ||
Copyright (c) 2022-2023 Bluesky PBC, and Contributors | ||
Copyright (c) 2022-2024 Bluesky PBC, and Contributors | ||
@@ -5,0 +5,0 @@ Except as otherwise noted in individual files, this software is licensed under the MIT license (<http://opensource.org/licenses/MIT>), or the Apache License, Version 2.0 (<http://www.apache.org/licenses/LICENSE-2.0>). |
{ | ||
"name": "@atproto/bsync", | ||
"version": "0.0.0", | ||
"version": "0.0.1", | ||
"license": "MIT", | ||
@@ -29,3 +29,3 @@ "description": "Sychronizing service for app.bsky App View (Bluesky API)", | ||
"@atproto/common": "^0.3.3", | ||
"@atproto/syntax": "^0.1.5" | ||
"@atproto/syntax": "^0.2.0" | ||
}, | ||
@@ -32,0 +32,0 @@ "devDependencies": { |
@@ -10,3 +10,3 @@ import { | ||
} from '@connectrpc/connect-node' | ||
import { Service } from './gen/bsync_connect' | ||
import { Service } from './proto/bsync_connect' | ||
@@ -13,0 +13,0 @@ export type BsyncClient = PromiseClient<typeof Service> |
import { GeneratedAlways, Selectable } from 'kysely' | ||
import { MuteOperation_Type } from '../../gen/bsync_pb' | ||
import { MuteOperation_Type } from '../../proto/bsync_pb' | ||
@@ -4,0 +4,0 @@ export interface MuteOp { |
@@ -47,2 +47,7 @@ import http from 'node:http' | ||
loggerMiddleware(req, res) | ||
if (isHealth(req.url)) { | ||
res.statusCode = 200 | ||
res.setHeader('content-type', 'application/json') | ||
return res.end(JSON.stringify({ version: cfg.service.version })) | ||
} | ||
handler(req, res) | ||
@@ -93,1 +98,7 @@ }) | ||
export default BsyncService | ||
const isHealth = (urlStr: string | undefined) => { | ||
if (!urlStr) return false | ||
const url = new URL(urlStr, 'http://host') | ||
return url.pathname === '/_health' | ||
} |
@@ -9,4 +9,4 @@ import { sql } from 'kysely' | ||
import { Code, ConnectError, ServiceImpl } from '@connectrpc/connect' | ||
import { Service } from '../gen/bsync_connect' | ||
import { AddMuteOperationResponse, MuteOperation_Type } from '../gen/bsync_pb' | ||
import { Service } from '../proto/bsync_connect' | ||
import { AddMuteOperationResponse, MuteOperation_Type } from '../proto/bsync_pb' | ||
import AppContext from '../context' | ||
@@ -13,0 +13,0 @@ import { createMuteOpChannel } from '../db/schema/mute_op' |
import { sql } from 'kysely' | ||
import { ConnectRouter } from '@connectrpc/connect' | ||
import { Service } from '../gen/bsync_connect' | ||
import { Service } from '../proto/bsync_connect' | ||
import AppContext from '../context' | ||
@@ -5,0 +5,0 @@ import addMuteOperation from './add-mute-operation' |
import { once } from 'node:events' | ||
import { Code, ConnectError, ServiceImpl } from '@connectrpc/connect' | ||
import { Service } from '../gen/bsync_connect' | ||
import { ScanMuteOperationsResponse } from '../gen/bsync_pb' | ||
import { Service } from '../proto/bsync_connect' | ||
import { ScanMuteOperationsResponse } from '../proto/bsync_pb' | ||
import AppContext from '../context' | ||
@@ -6,0 +6,0 @@ import { createMuteOpChannel } from '../db/schema/mute_op' |
@@ -11,3 +11,3 @@ import { wait } from '@atproto/common' | ||
} from '../src' | ||
import { MuteOperation, MuteOperation_Type } from '../src/gen/bsync_pb' | ||
import { MuteOperation, MuteOperation_Type } from '../src/proto/bsync_pb' | ||
@@ -14,0 +14,0 @@ describe('mutes', () => { |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
8587668
53
78673
+ Added@atproto/syntax@0.2.1(transitive)
- Removed@atproto/syntax@0.1.5(transitive)
Updated@atproto/syntax@^0.2.0