Compare commits
9 Commits
main
...
70ffea1a5c
| Author | SHA1 | Date | |
|---|---|---|---|
| 70ffea1a5c | |||
| a001b99fcd | |||
093fb0d85e
|
|||
|
7c5ef8af61
|
|||
|
2ddc74ed50
|
|||
|
d3ef21a67d
|
|||
|
bf2808eedc
|
|||
|
b0bd67b279
|
|||
|
e712a5adcb
|
Submodule .config/ai/scpt updated: 7a4d642e41...67771670f8
@ -1,18 +0,0 @@
|
|||||||
name: Gitea Actions Demo
|
|
||||||
run-name: ${{ gitea.actor }} is testing out Gitea Actions 🚀
|
|
||||||
on: [push]
|
|
||||||
jobs:
|
|
||||||
Explore-Gitea-Actions:
|
|
||||||
runs-on: ubuntu-latest
|
|
||||||
steps:
|
|
||||||
- run: echo "🎉 The job was automatically triggered by a ${{ gitea.event_name }} event."
|
|
||||||
- run: echo "🐧 This job is now running on a ${{ runner.os }} server hosted by Gitea!"
|
|
||||||
- run: echo "🔎 The name of your branch is ${{ gitea.ref }} and your repository is ${{ gitea.repository }}."
|
|
||||||
- name: Check out repository code
|
|
||||||
uses: actions/checkout@v3
|
|
||||||
- run: echo "💡 The ${{ gitea.repository }} repository has been cloned to the runner."
|
|
||||||
- run: echo "🖥️ The workflow is now ready to test your code on the runner."
|
|
||||||
- name: List files in the repository
|
|
||||||
run: |
|
|
||||||
ls ${{ gitea.workspace }}
|
|
||||||
- run: echo "🍏 This job's status is ${{ gitea.status }}."
|
|
||||||
7
.gitignore
vendored
7
.gitignore
vendored
@ -1,6 +1,6 @@
|
|||||||
Cargo.lock
|
Cargo.lock
|
||||||
target
|
target
|
||||||
#*.json
|
*.json
|
||||||
*.DS_Store
|
*.DS_Store
|
||||||
**.DS_Store
|
**.DS_Store
|
||||||
scpt/json/
|
scpt/json/
|
||||||
@ -12,8 +12,3 @@ scpt/json/
|
|||||||
.ssh/*.pub
|
.ssh/*.pub
|
||||||
.ssh/*config
|
.ssh/*config
|
||||||
.env
|
.env
|
||||||
|
|
||||||
pnpm-lock.yaml
|
|
||||||
**Cargo.lock
|
|
||||||
*/target/
|
|
||||||
*/**/*.rs.bk
|
|
||||||
|
|||||||
@ -1,9 +1,7 @@
|
|||||||
[package]
|
[package]
|
||||||
name = "ai"
|
name = "ai"
|
||||||
authors = ["syui"]
|
version = "0.0.1"
|
||||||
version = "0.1.0"
|
|
||||||
edition = "2021"
|
edition = "2021"
|
||||||
description = "latest@2024-08-18"
|
|
||||||
|
|
||||||
[dependencies]
|
[dependencies]
|
||||||
seahorse = "*"
|
seahorse = "*"
|
||||||
|
|||||||
@ -1,4 +1,5 @@
|
|||||||
FROM syui/aios
|
FROM syui/aios
|
||||||
|
ADD .ssh /root/.ssh
|
||||||
|
|
||||||
WORKDIR /root
|
WORKDIR /root
|
||||||
ADD ./test/entrypoint.sh .
|
ADD ./test/entrypoint.sh .
|
||||||
|
|||||||
65
README.md
65
README.md
@ -10,11 +10,7 @@
|
|||||||
$ ai
|
$ ai
|
||||||
```
|
```
|
||||||
|
|
||||||
```sh
|
### logo
|
||||||
$ docker run -it syui/aios ai
|
|
||||||
```
|
|
||||||
|
|
||||||
### build
|
|
||||||
|
|
||||||
```sh
|
```sh
|
||||||
$ cargo build
|
$ cargo build
|
||||||
@ -63,19 +59,15 @@ $ ai bot
|
|||||||
|
|
||||||
|command|sub|type|link|auth|
|
|command|sub|type|link|auth|
|
||||||
|---|---|---|---|---|
|
|---|---|---|---|---|
|
||||||
|/did||mention, reply| [plc.directory](https://plc.directory)/$did/log |user|
|
|@yui.syui.ai did||mention, reply| [plc.directory](https://plc.directory)/$did/log |user|
|
||||||
|/card|r, s, b|mention, reply| [card.syui.ai](https://card.syui.ai) |user|
|
|@yui.syui.ai card|r, s, b|mention, reply| [card.syui.ai](https://card.syui.ai) |user|
|
||||||
|/ten|start, close, d, p|mention, reply| [card.syui.ai](https://card.syui.ai) |user|
|
|@yui.syui.ai ten|start, d, p, coin|mention, reply| [card.syui.ai](https://card.syui.ai) |user|
|
||||||
|/fav|{cid}|mention, reply| [card.syui.ai](https://card.syui.ai) |user|
|
|@yui.syui.ai fav|{cid}|mention, reply| [card.syui.ai](https://card.syui.ai) |user|
|
||||||
|/egg|{password}|mention, reply| [card.syui.ai](https://card.syui.ai) |user|
|
|@yui.syui.ai egg|{password}|mention, reply| [card.syui.ai](https://card.syui.ai) |user|
|
||||||
|/nyan|🍬|mention, reply| [yui.syui.ai](https://yui.syui.ai) |user|
|
|@yui.syui.ai 占い||mention, reply| [yui.syui.ai](https://yui.syui.ai) |user|
|
||||||
|/diffusers|{keyword}|mention, reply| [huggingface.co/diffusers](https://huggingface.co/docs/diffusers/index) |user|
|
|@yui.syui.ai nyan|🍰|mention, reply| [yui.syui.ai](https://yui.syui.ai) |user|
|
||||||
|/sh|{command}|mention, reply| [archlinux.org](https://wiki.archlinux.org/title/Systemd-nspawn) |admin|
|
|@yui.syui.ai diffusers|{keyword}|mention, reply| [huggingface.co/diffusers](https://huggingface.co/docs/diffusers/index) |user|
|
||||||
|/占い||mention, reply| [yui.syui.ai](https://yui.syui.ai) |user|
|
|@yui.syui.ai sh|{command}|mention, reply| [archlinux.org](https://wiki.archlinux.org/title/Systemd-nspawn) |admin|
|
||||||
|
|
||||||
```sh
|
|
||||||
@yui.syui.ai /did
|
|
||||||
```
|
|
||||||
|
|
||||||
### test
|
### test
|
||||||
|
|
||||||
@ -92,6 +84,7 @@ $ cargo install --force cargo-make
|
|||||||
$ cargo make build
|
$ cargo make build
|
||||||
```
|
```
|
||||||
|
|
||||||
|
|
||||||
### docker
|
### docker
|
||||||
|
|
||||||
> .env
|
> .env
|
||||||
@ -104,41 +97,7 @@ ADMIN=syui.syu.is
|
|||||||
```
|
```
|
||||||
|
|
||||||
```sh
|
```sh
|
||||||
|
$ mkdir .ssh
|
||||||
$ docker compose build
|
$ docker compose build
|
||||||
$ docker compose up -d
|
$ docker compose up -d
|
||||||
```
|
```
|
||||||
|
|
||||||
## pds:card
|
|
||||||
|
|
||||||
- https://atproto.com/ja/guides/lexicon
|
|
||||||
- https://at.syu.is/at/did:plc:uqzpqmrjnptsxezjx4xuh2mn/ai.syui.card/3lagpwihqxi2v
|
|
||||||
|
|
||||||
```sh
|
|
||||||
# oauth(button)
|
|
||||||
[yui]ai.syui.card.verify -> [user]ai.syui.card
|
|
||||||
|
|
||||||
[yui]
|
|
||||||
$ ./target/debug/ai card-verify -i 0 -p 0 -r 0 -h syui.ai -d did:plc:uqzpqmrjnptsxezjx4xuh2mn
|
|
||||||
{"uri":"at://did:plc:4hqjfn7m6n5hno3doamuhgef/ai.syui.card.verify/3lagpvhppmd2q"}
|
|
||||||
|
|
||||||
[user]
|
|
||||||
$ ./target/debug/ai card -i 0 -p 0 -r 0 -v at://did:plc:4hqjfn7m6n5hno3doamuhgef/ai.syui.card.verify/3lagpvhppmd2q
|
|
||||||
```
|
|
||||||
|
|
||||||
## pds:game
|
|
||||||
|
|
||||||
- https://atproto.com/ja/specs/record-key
|
|
||||||
- https://at.syu.is/at/did:plc:uqzpqmrjnptsxezjx4xuh2mn/ai.syui.game/self
|
|
||||||
|
|
||||||
```sh
|
|
||||||
# oauth(play)
|
|
||||||
[yui]ai.syui.game.user -> [user]ai.syui.game
|
|
||||||
|
|
||||||
[account]
|
|
||||||
# https://at.syu.is/at/did:plc:4hqjfn7m6n5hno3doamuhgef/ai.syui.game.user/syui
|
|
||||||
## [rkey]
|
|
||||||
1. echo $handle|cut -d . -f 1
|
|
||||||
2. $handle
|
|
||||||
3. tid
|
|
||||||
```
|
|
||||||
|
|
||||||
|
|||||||
@ -1,10 +0,0 @@
|
|||||||
FEEDGEN_PORT=3000
|
|
||||||
FEEDGEN_LISTENHOST="0.0.0.0"
|
|
||||||
FEEDGEN_SQLITE_LOCATION="/data/db.sqlite"
|
|
||||||
FEEDGEN_SUBSCRIPTION_ENDPOINT="wss://bgs.syu.is"
|
|
||||||
FEEDGEN_PUBLISHER_DID="did:web:feed.syu.is"
|
|
||||||
FEEDGEN_HOSTNAME="feed.syu.is"
|
|
||||||
|
|
||||||
FEEDGEN_SUBSCRIPTION_RECONNECT_DELAY=3000
|
|
||||||
FEEDGEN_PUBLISHER_DID=did:plc:4hqjfn7m6n5hno3doamuhgef
|
|
||||||
FEEDGEN_SUBSCRIPTION_ENDPOINT="wss://bsky.network"
|
|
||||||
@ -1,26 +0,0 @@
|
|||||||
# custom feed
|
|
||||||
|
|
||||||
- at://did:plc:4hqjfn7m6n5hno3doamuhgef/app.bsky.feed.generator/cmd
|
|
||||||
- [bsky.app](https://bsky.app/profile/did:plc:4hqjfn7m6n5hno3doamuhgef/feed/cmd)
|
|
||||||
- [app.bsky.feed.getFeedSkeleton](https://feed.syu.is/xrpc/app.bsky.feed.getFeedSkeleton?feed=at://did:plc:4hqjfn7m6n5hno3doamuhgef/app.bsky.feed.generator/cmd)
|
|
||||||
|
|
||||||
```sh
|
|
||||||
did=did:plc:4hqjfn7m6n5hno3doamuhgef
|
|
||||||
col=app.bsky.feed.generator
|
|
||||||
cid=cmd
|
|
||||||
uri=at://$did/$col/$cid
|
|
||||||
|
|
||||||
echo $uri
|
|
||||||
```
|
|
||||||
|
|
||||||
## bsky-feed
|
|
||||||
|
|
||||||
```sh
|
|
||||||
$ git clone https://github.com/bluesky-social/feed-generator
|
|
||||||
```
|
|
||||||
|
|
||||||
```sh
|
|
||||||
docker compose build feed-generator
|
|
||||||
docker build -t publish_feed -f Dockerfile.feed .
|
|
||||||
docker run publish_feed
|
|
||||||
```
|
|
||||||
@ -1,43 +0,0 @@
|
|||||||
import { InvalidRequestError } from '@atproto/xrpc-server'
|
|
||||||
import { QueryParams } from '../lexicon/types/app/bsky/feed/getFeedSkeleton'
|
|
||||||
import { AppContext } from '../config'
|
|
||||||
|
|
||||||
// max 15 chars
|
|
||||||
export const shortname = 'cmd'
|
|
||||||
|
|
||||||
export const handler = async (ctx: AppContext, params: QueryParams) => {
|
|
||||||
let builder = ctx.db
|
|
||||||
.selectFrom('post')
|
|
||||||
.selectAll()
|
|
||||||
.orderBy('indexedAt', 'desc')
|
|
||||||
.orderBy('cid', 'desc')
|
|
||||||
.limit(params.limit)
|
|
||||||
|
|
||||||
if (params.cursor) {
|
|
||||||
const [indexedAt, cid] = params.cursor.split('::')
|
|
||||||
if (!indexedAt || !cid) {
|
|
||||||
throw new InvalidRequestError('malformed cursor')
|
|
||||||
}
|
|
||||||
const timeStr = new Date(parseInt(indexedAt, 10)).toISOString()
|
|
||||||
builder = builder
|
|
||||||
.where('post.indexedAt', '<', timeStr)
|
|
||||||
.orWhere((qb) => qb.where('post.indexedAt', '=', timeStr))
|
|
||||||
.where('post.cid', '<', cid)
|
|
||||||
}
|
|
||||||
const res = await builder.execute()
|
|
||||||
|
|
||||||
const feed = res.map((row) => ({
|
|
||||||
post: row.uri,
|
|
||||||
}))
|
|
||||||
|
|
||||||
let cursor: string | undefined
|
|
||||||
const last = res.at(-1)
|
|
||||||
if (last) {
|
|
||||||
cursor = `${new Date(last.indexedAt).getTime()}::${last.cid}`
|
|
||||||
}
|
|
||||||
|
|
||||||
return {
|
|
||||||
cursor,
|
|
||||||
feed,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,14 +0,0 @@
|
|||||||
import { AppContext } from '../config'
|
|
||||||
import {
|
|
||||||
QueryParams,
|
|
||||||
OutputSchema as AlgoOutput,
|
|
||||||
} from '../lexicon/types/app/bsky/feed/getFeedSkeleton'
|
|
||||||
import * as cmd from './cmd'
|
|
||||||
|
|
||||||
type AlgoHandler = (ctx: AppContext, params: QueryParams) => Promise<AlgoOutput>
|
|
||||||
|
|
||||||
const algos: Record<string, AlgoHandler> = {
|
|
||||||
[cmd.shortname]: cmd.handler,
|
|
||||||
}
|
|
||||||
|
|
||||||
export default algos
|
|
||||||
@ -1,50 +0,0 @@
|
|||||||
import {
|
|
||||||
OutputSchema as RepoEvent,
|
|
||||||
isCommit,
|
|
||||||
} from './lexicon/types/com/atproto/sync/subscribeRepos'
|
|
||||||
import { FirehoseSubscriptionBase, getOpsByType } from './util/subscription'
|
|
||||||
|
|
||||||
export class FirehoseSubscription extends FirehoseSubscriptionBase {
|
|
||||||
async handleEvent(evt: RepoEvent) {
|
|
||||||
if (!isCommit(evt)) return
|
|
||||||
const ops = await getOpsByType(evt)
|
|
||||||
|
|
||||||
// This logs the text of every post off the firehose.
|
|
||||||
// Just for fun :)
|
|
||||||
// Delete before actually using
|
|
||||||
for (const post of ops.posts.creates) {
|
|
||||||
console.log(post.record.text)
|
|
||||||
}
|
|
||||||
|
|
||||||
const postsToDelete = ops.posts.deletes.map((del) => del.uri)
|
|
||||||
const postsToCreate = ops.posts.creates
|
|
||||||
.filter((create) => {
|
|
||||||
return create.record.text.match('^/[a-z]') || create.record.text.match('^@ai ') || create.record.text.match('/ai ');
|
|
||||||
//return create.record.text.toLowerCase().includes('alf')
|
|
||||||
})
|
|
||||||
.map((create) => {
|
|
||||||
// map alf-related posts to a db row
|
|
||||||
return {
|
|
||||||
uri: create.uri,
|
|
||||||
cid: create.cid,
|
|
||||||
replyParent: create.record?.reply?.parent.uri ?? null,
|
|
||||||
replyRoot: create.record?.reply?.root.uri ?? null,
|
|
||||||
indexedAt: new Date().toISOString(),
|
|
||||||
}
|
|
||||||
})
|
|
||||||
|
|
||||||
if (postsToDelete.length > 0) {
|
|
||||||
await this.db
|
|
||||||
.deleteFrom('post')
|
|
||||||
.where('uri', 'in', postsToDelete)
|
|
||||||
.execute()
|
|
||||||
}
|
|
||||||
if (postsToCreate.length > 0) {
|
|
||||||
await this.db
|
|
||||||
.insertInto('post')
|
|
||||||
.values(postsToCreate)
|
|
||||||
.onConflict((oc) => oc.doNothing())
|
|
||||||
.execute()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,38 +0,0 @@
|
|||||||
## curl
|
|
||||||
|
|
||||||
no-authorization
|
|
||||||
|
|
||||||
https://docs.bsky.app/docs/api/com-atproto-repo-describe-repo
|
|
||||||
|
|
||||||
```sh
|
|
||||||
handle=yui.syui.ai
|
|
||||||
host=bsky.social
|
|
||||||
api=$host/xrpc
|
|
||||||
plc=plc.directory
|
|
||||||
url=$api/com.atproto.repo.describeRepo
|
|
||||||
|
|
||||||
curl -sL ${host}/xrpc/_health
|
|
||||||
|
|
||||||
d=`curl -sL "${url}?repo=$handle"`
|
|
||||||
echo $d
|
|
||||||
did=`echo $d|jq -r .did`
|
|
||||||
echo $did
|
|
||||||
|
|
||||||
collection=app.bsky.feed.post
|
|
||||||
url=$api/com.atproto.repo.listRecords
|
|
||||||
timed=`curl -sL "${url}?repo=$handle&collection=$collection&reverse=true&limit=1"|jq -r ".[]|.[0]?|.value.createdAt"`
|
|
||||||
cid=`curl -sL "${url}?repo=$handle&collection=$collection&reverse=true&limit=1"|jq -r ".[]|.[0]?|.cid"`
|
|
||||||
uri=`curl -sL "${url}?repo=$handle&collection=$collection&reverse=true&limit=1"|jq -r ".[]|.[0]?|.uri"`
|
|
||||||
|
|
||||||
rkey=`echo $uri|cut -d / -f 5`
|
|
||||||
url=$api/com.atproto.repo.getRecord
|
|
||||||
curl -sL "$url?repo=$did&collection=$collection&rkey=$rkey"|jq .
|
|
||||||
|
|
||||||
uri=at://did:plc:vjug55kidv6sye7ykr5faxxn/app.bsky.feed.post/3jzn6g7ixgq2y
|
|
||||||
cid=bafyreiey2tt4dhvuvr7tofatdverqrxmscnnus2uyfcmkacn2fov3vb4wa
|
|
||||||
did=did:plc:vjug55kidv6sye7ykr5faxxn
|
|
||||||
rkey=3jzn6g7ixgq2y
|
|
||||||
url=$api/com.atproto.repo.getRecord
|
|
||||||
curl -sL "$url?repo=$did&collection=$collection&rkey=$rkey&cid="|jq .
|
|
||||||
```
|
|
||||||
|
|
||||||
184
docs/wiki.md
184
docs/wiki.md
@ -1,11 +1,4 @@
|
|||||||
## test-notify
|
### docker
|
||||||
|
|
||||||
```sh
|
|
||||||
./target/debug/ai n|jq -r ".notifications|.[].cid" >> ~/.config/ai/txt/notify_cid*
|
|
||||||
./target/debug/ai bot
|
|
||||||
```
|
|
||||||
|
|
||||||
## docker
|
|
||||||
|
|
||||||
```sh
|
```sh
|
||||||
$ docker run -it syui/aios ai
|
$ docker run -it syui/aios ai
|
||||||
@ -18,7 +11,7 @@ $ cp -rf ~/.config/ai ./.config/
|
|||||||
$ docker compose up
|
$ docker compose up
|
||||||
```
|
```
|
||||||
|
|
||||||
## cron
|
### cron
|
||||||
|
|
||||||
```sh
|
```sh
|
||||||
$ sudo pacman -S fcron
|
$ sudo pacman -S fcron
|
||||||
@ -26,7 +19,7 @@ $ fcrontab -e
|
|||||||
* * * * * $HOME/bot/test/ai.zsh c
|
* * * * * $HOME/bot/test/ai.zsh c
|
||||||
```
|
```
|
||||||
|
|
||||||
## ssh
|
### ssh
|
||||||
|
|
||||||
```sh
|
```sh
|
||||||
$ ssh-keygen -f /.ssh/diffusers.key -t ed25519
|
$ ssh-keygen -f /.ssh/diffusers.key -t ed25519
|
||||||
@ -57,174 +50,3 @@ services:
|
|||||||
- ./.config:/root/.config
|
- ./.config:/root/.config
|
||||||
command: ai bot -a syui.syu.is
|
command: ai bot -a syui.syu.is
|
||||||
```
|
```
|
||||||
|
|
||||||
## openapi
|
|
||||||
|
|
||||||
```sh
|
|
||||||
# https://github.com/rdmurphy/atproto-openapi-types
|
|
||||||
$ curl -sLO https://raw.githubusercontent.com/rdmurphy/atproto-openapi-types/main/spec/api.json
|
|
||||||
```
|
|
||||||
|
|
||||||
## plc
|
|
||||||
|
|
||||||
```sh
|
|
||||||
# 何度か実行するとplcをlatestまでexportされる
|
|
||||||
$ .config/ai/scpt/test/pds.zsh e
|
|
||||||
```
|
|
||||||
|
|
||||||
## cmt
|
|
||||||
|
|
||||||
blogなどにblueskyアカウントのpostを表示します。
|
|
||||||
|
|
||||||
以下でbotがblogのコメントシステムを開きます。
|
|
||||||
|
|
||||||
```sh
|
|
||||||
@yui.syui.ai /comment https://syui.ai/blog/post/2024/04/25/bluesky/
|
|
||||||
```
|
|
||||||
|
|
||||||
開いたbotのpostに返信することで、特定のblog path上でpostを表示します。
|
|
||||||
|
|
||||||
<blockquote class="bluesky-embed" data-bluesky-uri="at://did:plc:4hqjfn7m6n5hno3doamuhgef/app.bsky.feed.post/3kqxbtmwlje2h" data-bluesky-cid="bafyreiasxp5g3nkkd6g7lxh55qaxcc7ylefaljmbcp627nu2geks62c57m"><p lang="">please reply with your comments here ↓
|
|
||||||
</p>— ai (<a href="https://bsky.app/profile/did:plc:4hqjfn7m6n5hno3doamuhgef?ref_src=embed">@yui.syui.ai</a>) <a href="https://bsky.app/profile/did:plc:4hqjfn7m6n5hno3doamuhgef/post/3kqxbtmwlje2h?ref_src=embed">Apr 25, 2024 at 20:18</a></blockquote><script async src="https://embed.bsky.app/static/embed.js" charset="utf-8"></script>
|
|
||||||
|
|
||||||
```ts
|
|
||||||
<link href="https://syui.ai/js/comment/app.js" rel="preload" as="script">
|
|
||||||
<link href="https://syui.ai/js/comment/chunk-vendors.js" rel="preload" as="script">
|
|
||||||
<div id="comment"></div>
|
|
||||||
<script async src="https://embed.bsky.app/static/embed.js" charset="utf-8"></script>
|
|
||||||
<script src="https://syui.ai/js/comment/chunk-vendors.js"></script>
|
|
||||||
<script src="https://syui.ai/js/comment/app.js"></script>
|
|
||||||
```
|
|
||||||
|
|
||||||
## example json
|
|
||||||
|
|
||||||
```json
|
|
||||||
[
|
|
||||||
{
|
|
||||||
"uri": "at://did:plc:wkzuqomvkxx5eiv5nl2lvm23/app.bsky.feed.post/3kp4ze5dcek2j",
|
|
||||||
"cid": "bafyreic4g7mthhw654zgv4skt5tqbs2xqg6n7bli4gayl2nquljngnotiy",
|
|
||||||
"author": {
|
|
||||||
"did": "did:plc:wkzuqomvkxx5eiv5nl2lvm23",
|
|
||||||
"handle": "syui.syu.is",
|
|
||||||
"displayName": "syui",
|
|
||||||
"avatar": "https://api.syu.is/img/avatar/plain/did:plc:wkzuqomvkxx5eiv5nl2lvm23/bafkreifvabvstfgawt6csagh44xdevb6c2uiwpgfho3xnpdrr6o7nbkxry@jpeg",
|
|
||||||
"indexedAt": "2024-01-14T10:20:13.367Z",
|
|
||||||
"viewer": {
|
|
||||||
"muted": false,
|
|
||||||
"blockedBy": false,
|
|
||||||
"following": "at://did:plc:dconvttcori3mrh2wrmehvwt/app.bsky.graph.follow/3kiztjatnms25",
|
|
||||||
"followedBy": "at://did:plc:wkzuqomvkxx5eiv5nl2lvm23/app.bsky.graph.follow/3kirwsboeos26"
|
|
||||||
},
|
|
||||||
"labels": []
|
|
||||||
},
|
|
||||||
"reason": "reply",
|
|
||||||
"reasonSubject": "at://did:plc:dconvttcori3mrh2wrmehvwt/app.bsky.feed.post/3kp4zdnlo5s2j",
|
|
||||||
"record": {
|
|
||||||
"text": "1",
|
|
||||||
"$type": "app.bsky.feed.post",
|
|
||||||
"langs": [
|
|
||||||
"ja"
|
|
||||||
],
|
|
||||||
"reply": {
|
|
||||||
"root": {
|
|
||||||
"cid": "bafyreiceckunxajycacn7dbuojrwb2wmurhfkleermvewwik44cn6vqo3a",
|
|
||||||
"uri": "at://did:plc:dconvttcori3mrh2wrmehvwt/app.bsky.feed.post/3kp4zdnlo5s2j"
|
|
||||||
},
|
|
||||||
"parent": {
|
|
||||||
"cid": "bafyreiceckunxajycacn7dbuojrwb2wmurhfkleermvewwik44cn6vqo3a",
|
|
||||||
"uri": "at://did:plc:dconvttcori3mrh2wrmehvwt/app.bsky.feed.post/3kp4zdnlo5s2j"
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"createdAt": "2024-04-02T07:12:28.799Z"
|
|
||||||
},
|
|
||||||
"isRead": true,
|
|
||||||
"indexedAt": "2024-04-02T07:12:28.799Z",
|
|
||||||
"labels": []
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"uri": "at://did:plc:wkzuqomvkxx5eiv5nl2lvm23/app.bsky.feed.post/3kp54af2zes2j",
|
|
||||||
"cid": "bafyreig4kvfpu557qehttt2y5eh7rcyodbxqwtnl73f3fhjsstiap3abzu",
|
|
||||||
"author": {
|
|
||||||
"did": "did:plc:wkzuqomvkxx5eiv5nl2lvm23",
|
|
||||||
"handle": "syui.syu.is",
|
|
||||||
"displayName": "syui",
|
|
||||||
"avatar": "https://api.syu.is/img/avatar/plain/did:plc:wkzuqomvkxx5eiv5nl2lvm23/bafkreifvabvstfgawt6csagh44xdevb6c2uiwpgfho3xnpdrr6o7nbkxry@jpeg",
|
|
||||||
"indexedAt": "2024-01-14T10:20:13.367Z",
|
|
||||||
"viewer": {
|
|
||||||
"muted": false,
|
|
||||||
"blockedBy": false,
|
|
||||||
"following": "at://did:plc:dconvttcori3mrh2wrmehvwt/app.bsky.graph.follow/3kiztjatnms25",
|
|
||||||
"followedBy": "at://did:plc:wkzuqomvkxx5eiv5nl2lvm23/app.bsky.graph.follow/3kirwsboeos26"
|
|
||||||
},
|
|
||||||
"labels": []
|
|
||||||
},
|
|
||||||
"reason": "reply",
|
|
||||||
"reasonSubject": "at://did:plc:dconvttcori3mrh2wrmehvwt/app.bsky.feed.post/3kp4zdnlo5s2j",
|
|
||||||
"record": {
|
|
||||||
"text": "2",
|
|
||||||
"$type": "app.bsky.feed.post",
|
|
||||||
"langs": [
|
|
||||||
"ja"
|
|
||||||
],
|
|
||||||
"reply": {
|
|
||||||
"root": {
|
|
||||||
"cid": "bafyreiceckunxajycacn7dbuojrwb2wmurhfkleermvewwik44cn6vqo3a",
|
|
||||||
"uri": "at://did:plc:dconvttcori3mrh2wrmehvwt/app.bsky.feed.post/3kp4zdnlo5s2j"
|
|
||||||
},
|
|
||||||
"parent": {
|
|
||||||
"cid": "bafyreiceckunxajycacn7dbuojrwb2wmurhfkleermvewwik44cn6vqo3a",
|
|
||||||
"uri": "at://did:plc:dconvttcori3mrh2wrmehvwt/app.bsky.feed.post/3kp4zdnlo5s2j"
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"createdAt": "2024-04-02T08:04:03.938Z"
|
|
||||||
},
|
|
||||||
"isRead": true,
|
|
||||||
"indexedAt": "2024-04-02T08:04:03.938Z",
|
|
||||||
"labels": []
|
|
||||||
}
|
|
||||||
]
|
|
||||||
```
|
|
||||||
|
|
||||||
```json
|
|
||||||
{
|
|
||||||
"uri": "at://did:plc:uqzpqmrjnptsxezjx4xuh2mn/app.bsky.feed.post/3kp5qniyzm42h",
|
|
||||||
"cid": "bafyreihmutmtf2clpgmx5l3qpu6xea6z25xrop74mltsycs5lfacm27u6e",
|
|
||||||
"author": {
|
|
||||||
"did": "did:plc:uqzpqmrjnptsxezjx4xuh2mn",
|
|
||||||
"handle": "syui.ai",
|
|
||||||
"displayName": "syui",
|
|
||||||
"avatar": "https://cdn.bsky.app/img/avatar/plain/did:plc:uqzpqmrjnptsxezjx4xuh2mn/bafkreid6kcc5pnn4b3ar7mj6vi3eiawhxgkcrw3edgbqeacyrlnlcoetea@jpeg",
|
|
||||||
"viewer": {
|
|
||||||
"muted": false,
|
|
||||||
"blockedBy": false,
|
|
||||||
"followedBy": "at://did:plc:uqzpqmrjnptsxezjx4xuh2mn/app.bsky.graph.follow/3kkvst5iq6r2a"
|
|
||||||
},
|
|
||||||
"labels": [],
|
|
||||||
"description": "https://syui.ai",
|
|
||||||
"indexedAt": "2024-01-25T23:54:12.979Z"
|
|
||||||
},
|
|
||||||
"reason": "reply",
|
|
||||||
"reasonSubject": "at://did:plc:4hqjfn7m6n5hno3doamuhgef/app.bsky.feed.post/3kp5qn72s232q",
|
|
||||||
"record": {
|
|
||||||
"$type": "app.bsky.feed.post",
|
|
||||||
"createdAt": "2024-04-02T14:09:18.926Z",
|
|
||||||
"langs": [
|
|
||||||
"ja"
|
|
||||||
],
|
|
||||||
"reply": {
|
|
||||||
"parent": {
|
|
||||||
"cid": "bafyreiewdfyh6rywpkdzpmf5markqa6tavc5smc32q7cw2wpwbqik5hnfm",
|
|
||||||
"uri": "at://did:plc:4hqjfn7m6n5hno3doamuhgef/app.bsky.feed.post/3kp5qn72s232q"
|
|
||||||
},
|
|
||||||
"root": {
|
|
||||||
"cid": "bafyreiewdfyh6rywpkdzpmf5markqa6tavc5smc32q7cw2wpwbqik5hnfm",
|
|
||||||
"uri": "at://did:plc:4hqjfn7m6n5hno3doamuhgef/app.bsky.feed.post/3kp5qn72s232q"
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"text": "first"
|
|
||||||
},
|
|
||||||
"isRead": true,
|
|
||||||
"indexedAt": "2024-04-02T14:09:18.926Z",
|
|
||||||
"labels": []
|
|
||||||
}
|
|
||||||
```
|
|
||||||
|
|||||||
836
src/bot.rs
836
src/bot.rs
File diff suppressed because it is too large
Load Diff
@ -34,7 +34,6 @@ pub fn log_file(s: &str) -> String {
|
|||||||
match &*s {
|
match &*s {
|
||||||
"n1" => f + &"notify_cid.txt",
|
"n1" => f + &"notify_cid.txt",
|
||||||
"n2" => f + &"notify_cid_run.txt",
|
"n2" => f + &"notify_cid_run.txt",
|
||||||
"c1" => f + &"comment_cid.txt",
|
|
||||||
_ => f + &s,
|
_ => f + &s,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -107,7 +106,6 @@ pub struct BaseUrl {
|
|||||||
pub record_list: String,
|
pub record_list: String,
|
||||||
pub record_create: String,
|
pub record_create: String,
|
||||||
pub record_delete: String,
|
pub record_delete: String,
|
||||||
pub record_put: String,
|
|
||||||
pub session_create: String,
|
pub session_create: String,
|
||||||
pub session_refresh: String,
|
pub session_refresh: String,
|
||||||
pub session_get: String,
|
pub session_get: String,
|
||||||
@ -125,7 +123,6 @@ pub struct BaseUrl {
|
|||||||
pub follow: String,
|
pub follow: String,
|
||||||
pub follows: String,
|
pub follows: String,
|
||||||
pub followers: String,
|
pub followers: String,
|
||||||
pub feed_get: String,
|
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn url(s: &str) -> String {
|
pub fn url(s: &str) -> String {
|
||||||
@ -143,7 +140,6 @@ pub fn url(s: &str) -> String {
|
|||||||
let baseurl = BaseUrl {
|
let baseurl = BaseUrl {
|
||||||
profile_get: "com.atproto.identity.resolveHandle".to_string(),
|
profile_get: "com.atproto.identity.resolveHandle".to_string(),
|
||||||
thread_get: "app.bsky.feed.getPostThread".to_string(),
|
thread_get: "app.bsky.feed.getPostThread".to_string(),
|
||||||
record_put: "com.atproto.repo.putRecord".to_string(),
|
|
||||||
record_create: "com.atproto.repo.createRecord".to_string(),
|
record_create: "com.atproto.repo.createRecord".to_string(),
|
||||||
record_delete: "com.atproto.repo.deleteRecord".to_string(),
|
record_delete: "com.atproto.repo.deleteRecord".to_string(),
|
||||||
describe: "com.atproto.repo.describeRepo".to_string(),
|
describe: "com.atproto.repo.describeRepo".to_string(),
|
||||||
@ -152,7 +148,6 @@ pub fn url(s: &str) -> String {
|
|||||||
session_refresh: "com.atproto.server.refreshSession".to_string(),
|
session_refresh: "com.atproto.server.refreshSession".to_string(),
|
||||||
session_get: "com.atproto.server.getSession".to_string(),
|
session_get: "com.atproto.server.getSession".to_string(),
|
||||||
timeline_get: "app.bsky.feed.getTimeline".to_string(),
|
timeline_get: "app.bsky.feed.getTimeline".to_string(),
|
||||||
feed_get: "app.bsky.feed.getFeed".to_string(),
|
|
||||||
timeline_author: "app.bsky.feed.getAuthorFeed".to_string(),
|
timeline_author: "app.bsky.feed.getAuthorFeed".to_string(),
|
||||||
like: "app.bsky.feed.like".to_string(),
|
like: "app.bsky.feed.like".to_string(),
|
||||||
repost: "app.bsky.feed.repost".to_string(),
|
repost: "app.bsky.feed.repost".to_string(),
|
||||||
@ -175,7 +170,6 @@ pub fn url(s: &str) -> String {
|
|||||||
"record_list" => t.to_string() + &baseurl.record_list,
|
"record_list" => t.to_string() + &baseurl.record_list,
|
||||||
"record_create" => t.to_string() + &baseurl.record_create,
|
"record_create" => t.to_string() + &baseurl.record_create,
|
||||||
"record_delete" => t.to_string() + &baseurl.record_delete,
|
"record_delete" => t.to_string() + &baseurl.record_delete,
|
||||||
"record_put" => t.to_string() + &baseurl.record_put,
|
|
||||||
"session_create" => t.to_string() + &baseurl.session_create,
|
"session_create" => t.to_string() + &baseurl.session_create,
|
||||||
"session_refresh" => t.to_string() + &baseurl.session_refresh,
|
"session_refresh" => t.to_string() + &baseurl.session_refresh,
|
||||||
"session_get" => t.to_string() + &baseurl.session_get,
|
"session_get" => t.to_string() + &baseurl.session_get,
|
||||||
@ -193,7 +187,6 @@ pub fn url(s: &str) -> String {
|
|||||||
"follow" => t.to_string() + &baseurl.follow,
|
"follow" => t.to_string() + &baseurl.follow,
|
||||||
"follows" => t.to_string() + &baseurl.follows,
|
"follows" => t.to_string() + &baseurl.follows,
|
||||||
"followers" => t.to_string() + &baseurl.followers,
|
"followers" => t.to_string() + &baseurl.followers,
|
||||||
"feed_get" => t.to_string() + &baseurl.feed_get,
|
|
||||||
_ => s,
|
_ => s,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@ -1,33 +0,0 @@
|
|||||||
extern crate reqwest;
|
|
||||||
use crate::data_toml;
|
|
||||||
use crate::data_refresh;
|
|
||||||
use crate::url;
|
|
||||||
use serde_json::json;
|
|
||||||
|
|
||||||
pub async fn post_request(rkey: String, col: String) -> String {
|
|
||||||
let token = data_refresh(&"access");
|
|
||||||
//let did = data_toml(&"did");
|
|
||||||
let handle = data_toml(&"handle");
|
|
||||||
|
|
||||||
let url = url(&"record_delete");
|
|
||||||
|
|
||||||
let post = Some(json!({
|
|
||||||
"repo": handle.to_string(),
|
|
||||||
"rkey": rkey.to_string(),
|
|
||||||
"collection": col.to_string()
|
|
||||||
}));
|
|
||||||
|
|
||||||
let client = reqwest::Client::new();
|
|
||||||
let res = client
|
|
||||||
.post(url)
|
|
||||||
.json(&post)
|
|
||||||
.header("Authorization", "Bearer ".to_owned() + &token)
|
|
||||||
.send()
|
|
||||||
.await
|
|
||||||
.unwrap()
|
|
||||||
.text()
|
|
||||||
.await
|
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
return res;
|
|
||||||
}
|
|
||||||
@ -1,33 +0,0 @@
|
|||||||
extern crate reqwest;
|
|
||||||
use crate::data_refresh;
|
|
||||||
use crate::url;
|
|
||||||
|
|
||||||
pub async fn get_request(feed: String) -> String {
|
|
||||||
let token = data_refresh(&"access");
|
|
||||||
let url = url(&"feed_get");
|
|
||||||
let feed = feed.to_string();
|
|
||||||
//let col = "app.bsky.feed.generator".to_string();
|
|
||||||
|
|
||||||
let client = reqwest::Client::new();
|
|
||||||
let res = client
|
|
||||||
.get(url)
|
|
||||||
.query(&[("feed", feed)])
|
|
||||||
//.query(&[("feed", feed), ("collection", col)])
|
|
||||||
.header("Authorization", "Bearer ".to_owned() + &token)
|
|
||||||
.send()
|
|
||||||
.await
|
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
let status_ref = res.error_for_status_ref();
|
|
||||||
|
|
||||||
match status_ref {
|
|
||||||
Ok(_) => {
|
|
||||||
return res.text().await.unwrap();
|
|
||||||
}
|
|
||||||
Err(_e) => {
|
|
||||||
let e = "err".to_string();
|
|
||||||
return e;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
@ -1,77 +0,0 @@
|
|||||||
use seahorse::Context;
|
|
||||||
|
|
||||||
//use crate::openai;
|
|
||||||
use crate::feed_get;
|
|
||||||
|
|
||||||
use crate::data::data_toml;
|
|
||||||
use crate::data::Timeline;
|
|
||||||
use crate::data::log_file;
|
|
||||||
use crate::data::w_cid;
|
|
||||||
|
|
||||||
pub fn c_feed_watch(c: &Context) {
|
|
||||||
let mut feed = "at://did:plc:4hqjfn7m6n5hno3doamuhgef/app.bsky.feed.generator/cmd".to_string();
|
|
||||||
if c.string_flag("url").is_ok() {
|
|
||||||
feed = c.string_flag("url").unwrap();
|
|
||||||
}
|
|
||||||
let mut tag = "syai".to_string();
|
|
||||||
if c.string_flag("tag").is_ok() {
|
|
||||||
tag = c.string_flag("tag").unwrap();
|
|
||||||
}
|
|
||||||
|
|
||||||
let h = async {
|
|
||||||
let notify = feed_get::get_request(feed).await;
|
|
||||||
if notify == "err" {
|
|
||||||
return;
|
|
||||||
//refresh(c);
|
|
||||||
//notify = feed_get::get_request("at://did:plc:4hqjfn7m6n5hno3doamuhgef/app.bsky.feed.generator/cmd".to_string()).await;
|
|
||||||
}
|
|
||||||
let timeline: Timeline = serde_json::from_str(¬ify).unwrap();
|
|
||||||
let n = timeline.feed;
|
|
||||||
let host = data_toml(&"host");
|
|
||||||
let length = &n.len();
|
|
||||||
let su = 0..*length;
|
|
||||||
for i in su {
|
|
||||||
let cid = &n[i].post.cid;
|
|
||||||
let check_cid = w_cid(cid.to_string(), log_file(&"n1"), false);
|
|
||||||
let handle = &n[i].post.author.handle;
|
|
||||||
let did = &n[i].post.author.did;
|
|
||||||
let uri = &n[i].post.uri;
|
|
||||||
let _time = &n[i].post.indexedAt;
|
|
||||||
let cid_root = cid;
|
|
||||||
let uri_root = uri;
|
|
||||||
let mut text = "";
|
|
||||||
if !n[i].post.record.text.is_none() {
|
|
||||||
text = &n[i].post.record.text.as_ref().unwrap();
|
|
||||||
}
|
|
||||||
|
|
||||||
let vec: Vec<&str> = text.split_whitespace().collect();
|
|
||||||
let com = vec[0].trim().to_string();
|
|
||||||
let mut prompt = "".to_string();
|
|
||||||
let mut prompt_sub = "".to_string();
|
|
||||||
|
|
||||||
if com == "@ai" || com == "/ai" || com == tag {
|
|
||||||
prompt_sub = vec[1..].join(" ");
|
|
||||||
} else {
|
|
||||||
prompt = vec[1..].join(" ");
|
|
||||||
if vec.len() > 1 {
|
|
||||||
prompt_sub = vec[2..].join(" ");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if check_cid == false && { prompt.is_empty() == false || com.is_empty() == false } {
|
|
||||||
println!("{}", handle);
|
|
||||||
if c.bool_flag("debug") == true {
|
|
||||||
println!(
|
|
||||||
"cid:{}\nuri:{}\ncid_root:{}\nuri_root:{}\nhost:{}\ndid:{}\ncheck_cid:{}",
|
|
||||||
cid, uri, cid_root, uri_root, host, did, check_cid
|
|
||||||
);
|
|
||||||
}
|
|
||||||
println!("{}", prompt_sub);
|
|
||||||
println!("---");
|
|
||||||
w_cid(cid.to_string(), log_file(&"n1"), true);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
};
|
|
||||||
let res = tokio::runtime::Runtime::new().unwrap().block_on(h);
|
|
||||||
return res;
|
|
||||||
}
|
|
||||||
@ -1,5 +0,0 @@
|
|||||||
pub mod post_card;
|
|
||||||
pub mod post_card_verify;
|
|
||||||
pub mod post_game;
|
|
||||||
pub mod post_game_user;
|
|
||||||
pub mod post_game_login;
|
|
||||||
@ -1,44 +0,0 @@
|
|||||||
extern crate reqwest;
|
|
||||||
use crate::data_toml;
|
|
||||||
use crate::data_refresh;
|
|
||||||
use crate::url;
|
|
||||||
use iso8601_timestamp::Timestamp;
|
|
||||||
use serde_json::json;
|
|
||||||
|
|
||||||
pub async fn post_request(verify: String, id: i32, cp: i32, rank: i32, rare: String, col: String, author: String) -> String {
|
|
||||||
let token = data_refresh(&"access");
|
|
||||||
let did = data_toml(&"did");
|
|
||||||
let handle = data_toml(&"handle");
|
|
||||||
let url = url(&"record_create");
|
|
||||||
let d = Timestamp::now_utc();
|
|
||||||
let d = d.to_string();
|
|
||||||
|
|
||||||
let post = Some(json!({
|
|
||||||
"repo": handle.to_string(),
|
|
||||||
"did": did.to_string(),
|
|
||||||
"collection": col.to_string(),
|
|
||||||
"record": {
|
|
||||||
"id": id,
|
|
||||||
"cp": cp,
|
|
||||||
"rank": rank,
|
|
||||||
"rare": rare.to_string(),
|
|
||||||
"author": author.to_string(),
|
|
||||||
"verify": verify.to_string(),
|
|
||||||
"createdAt": d.to_string(),
|
|
||||||
},
|
|
||||||
}));
|
|
||||||
|
|
||||||
let client = reqwest::Client::new();
|
|
||||||
let res = client
|
|
||||||
.post(url)
|
|
||||||
.json(&post)
|
|
||||||
.header("Authorization", "Bearer ".to_owned() + &token)
|
|
||||||
.send()
|
|
||||||
.await
|
|
||||||
.unwrap()
|
|
||||||
.text()
|
|
||||||
.await
|
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
return res;
|
|
||||||
}
|
|
||||||
@ -1,58 +0,0 @@
|
|||||||
extern crate reqwest;
|
|
||||||
use crate::data_toml;
|
|
||||||
use crate::data_refresh;
|
|
||||||
use crate::url;
|
|
||||||
use iso8601_timestamp::Timestamp;
|
|
||||||
use serde_json::json;
|
|
||||||
|
|
||||||
pub async fn post_request(col: String, img: String, id: i32, cp: i32, rank: i32, rare: String, user_handle: String, user_did: String) -> String {
|
|
||||||
let token = data_refresh(&"access");
|
|
||||||
let did = data_toml(&"did");
|
|
||||||
let handle = data_toml(&"handle");
|
|
||||||
let url = url(&"record_create");
|
|
||||||
let d = Timestamp::now_utc();
|
|
||||||
let d = d.to_string();
|
|
||||||
let link = "https://bsky.app/profile/yui.syui.ai".to_string();
|
|
||||||
let post = Some(json!({
|
|
||||||
"repo": handle.to_string(),
|
|
||||||
"did": did.to_string(),
|
|
||||||
"collection": col.to_string(),
|
|
||||||
"record": {
|
|
||||||
"id": id,
|
|
||||||
"cp": cp,
|
|
||||||
"rank": rank,
|
|
||||||
"rare": rare.to_string(),
|
|
||||||
"handle": user_handle.to_string(),
|
|
||||||
"did": user_did.to_string(),
|
|
||||||
"embed": {
|
|
||||||
"$type": "app.bsky.embed.external",
|
|
||||||
"external": {
|
|
||||||
"uri": link,
|
|
||||||
"thumb": {
|
|
||||||
"$type": "blob",
|
|
||||||
"ref": {
|
|
||||||
"$link": img.to_string()
|
|
||||||
},
|
|
||||||
"mimeType": "image/jpeg",
|
|
||||||
"size": 0
|
|
||||||
}
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"createdAt": d.to_string(),
|
|
||||||
},
|
|
||||||
}));
|
|
||||||
|
|
||||||
let client = reqwest::Client::new();
|
|
||||||
let res = client
|
|
||||||
.post(url)
|
|
||||||
.json(&post)
|
|
||||||
.header("Authorization", "Bearer ".to_owned() + &token)
|
|
||||||
.send()
|
|
||||||
.await
|
|
||||||
.unwrap()
|
|
||||||
.text()
|
|
||||||
.await
|
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
return res;
|
|
||||||
}
|
|
||||||
@ -1,39 +0,0 @@
|
|||||||
extern crate reqwest;
|
|
||||||
use crate::data_toml;
|
|
||||||
use crate::data_refresh;
|
|
||||||
use crate::url;
|
|
||||||
use iso8601_timestamp::Timestamp;
|
|
||||||
use serde_json::json;
|
|
||||||
|
|
||||||
pub async fn post_request(col: String, account: String) -> String {
|
|
||||||
let token = data_refresh(&"access");
|
|
||||||
let did = data_toml(&"did");
|
|
||||||
let handle = data_toml(&"handle");
|
|
||||||
let url = url(&"record_put");
|
|
||||||
let d = Timestamp::now_utc();
|
|
||||||
let d = d.to_string();
|
|
||||||
let post = Some(json!({
|
|
||||||
"repo": handle.to_string(),
|
|
||||||
"did": did.to_string(),
|
|
||||||
"collection": col.to_string(),
|
|
||||||
"rkey": "self".to_string(),
|
|
||||||
"record": {
|
|
||||||
"account": account.to_string(),
|
|
||||||
"createdAt": d.to_string(),
|
|
||||||
},
|
|
||||||
}));
|
|
||||||
|
|
||||||
let client = reqwest::Client::new();
|
|
||||||
let res = client
|
|
||||||
.post(url)
|
|
||||||
.json(&post)
|
|
||||||
.header("Authorization", "Bearer ".to_owned() + &token)
|
|
||||||
.send()
|
|
||||||
.await
|
|
||||||
.unwrap()
|
|
||||||
.text()
|
|
||||||
.await
|
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
return res;
|
|
||||||
}
|
|
||||||
@ -1,42 +0,0 @@
|
|||||||
extern crate reqwest;
|
|
||||||
use crate::data_toml;
|
|
||||||
use crate::data_refresh;
|
|
||||||
use crate::url;
|
|
||||||
use iso8601_timestamp::Timestamp;
|
|
||||||
use serde_json::json;
|
|
||||||
|
|
||||||
pub async fn post_request(col: String, username: String, login: bool, account: String) -> String {
|
|
||||||
let token = data_refresh(&"access");
|
|
||||||
let did = data_toml(&"did");
|
|
||||||
let handle = data_toml(&"handle");
|
|
||||||
let url = url(&"record_put");
|
|
||||||
let d = Timestamp::now_utc();
|
|
||||||
let d = d.to_string();
|
|
||||||
|
|
||||||
let post = Some(json!({
|
|
||||||
"repo": handle.to_string(),
|
|
||||||
"did": did.to_string(),
|
|
||||||
"collection": col.to_string(),
|
|
||||||
"rkey": "self".to_string(),
|
|
||||||
"record": {
|
|
||||||
"login": login,
|
|
||||||
"username": username.to_string(),
|
|
||||||
"account": account.to_string(),
|
|
||||||
"createdAt": d.to_string(),
|
|
||||||
},
|
|
||||||
}));
|
|
||||||
|
|
||||||
let client = reqwest::Client::new();
|
|
||||||
let res = client
|
|
||||||
.post(url)
|
|
||||||
.json(&post)
|
|
||||||
.header("Authorization", "Bearer ".to_owned() + &token)
|
|
||||||
.send()
|
|
||||||
.await
|
|
||||||
.unwrap()
|
|
||||||
.text()
|
|
||||||
.await
|
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
return res;
|
|
||||||
}
|
|
||||||
@ -1,55 +0,0 @@
|
|||||||
extern crate reqwest;
|
|
||||||
use crate::data_toml;
|
|
||||||
use crate::data_refresh;
|
|
||||||
use crate::url;
|
|
||||||
use iso8601_timestamp::Timestamp;
|
|
||||||
use serde_json::json;
|
|
||||||
|
|
||||||
pub async fn post_request(col: String, user_name: String, user_did: String, user_handle: String, aiten: i32, limit: i32, chara: String, lv: i32, exp: i32, hp: i32, rank: i32, mode: i32, attach: i32, critical: i32, critical_d: i32) -> String {
|
|
||||||
let token = data_refresh(&"access");
|
|
||||||
let did = data_toml(&"did");
|
|
||||||
let handle = data_toml(&"handle");
|
|
||||||
let url = url(&"record_put");
|
|
||||||
let d = Timestamp::now_utc();
|
|
||||||
let d = d.to_string();
|
|
||||||
let post = Some(json!({
|
|
||||||
"repo": handle.to_string(),
|
|
||||||
"did": did.to_string(),
|
|
||||||
"collection": col.to_string(),
|
|
||||||
"rkey": user_name.to_string(),
|
|
||||||
"record": {
|
|
||||||
"did": user_did.to_string(),
|
|
||||||
"handle": user_handle.to_string(),
|
|
||||||
"aiten": aiten,
|
|
||||||
"limit": limit,
|
|
||||||
"character": {
|
|
||||||
chara.to_string(): {
|
|
||||||
"lv": lv,
|
|
||||||
"exp": exp,
|
|
||||||
"hp": hp,
|
|
||||||
"rank": rank,
|
|
||||||
"mode": mode,
|
|
||||||
"attach": attach,
|
|
||||||
"critical": critical,
|
|
||||||
"critical_d": critical_d,
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"createdAt": d.to_string(),
|
|
||||||
"updatedAt": d.to_string(),
|
|
||||||
},
|
|
||||||
}));
|
|
||||||
|
|
||||||
let client = reqwest::Client::new();
|
|
||||||
let res = client
|
|
||||||
.post(url)
|
|
||||||
.json(&post)
|
|
||||||
.header("Authorization", "Bearer ".to_owned() + &token)
|
|
||||||
.send()
|
|
||||||
.await
|
|
||||||
.unwrap()
|
|
||||||
.text()
|
|
||||||
.await
|
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
return res;
|
|
||||||
}
|
|
||||||
389
src/main.rs
389
src/main.rs
@ -3,7 +3,6 @@ use std::env;
|
|||||||
|
|
||||||
use crate::ascii::c_ascii;
|
use crate::ascii::c_ascii;
|
||||||
use crate::bot::c_bot;
|
use crate::bot::c_bot;
|
||||||
use crate::bot::c_bot_feed;
|
|
||||||
use crate::data::c_follow_all;
|
use crate::data::c_follow_all;
|
||||||
use crate::data::c_openai_key;
|
use crate::data::c_openai_key;
|
||||||
use crate::data::data_toml;
|
use crate::data::data_toml;
|
||||||
@ -11,12 +10,6 @@ use crate::data::data_refresh;
|
|||||||
use crate::data::url;
|
use crate::data::url;
|
||||||
use crate::data::w_cfg;
|
use crate::data::w_cfg;
|
||||||
use crate::data::w_refresh;
|
use crate::data::w_refresh;
|
||||||
use crate::feed_watch::c_feed_watch;
|
|
||||||
use crate::game::post_card;
|
|
||||||
use crate::game::post_card_verify;
|
|
||||||
use crate::game::post_game;
|
|
||||||
use crate::game::post_game_user;
|
|
||||||
use crate::game::post_game_login;
|
|
||||||
|
|
||||||
use data::ProfileIdentityResolve;
|
use data::ProfileIdentityResolve;
|
||||||
|
|
||||||
@ -35,7 +28,6 @@ pub mod notify_read;
|
|||||||
pub mod openai;
|
pub mod openai;
|
||||||
pub mod post;
|
pub mod post;
|
||||||
pub mod post_link;
|
pub mod post_link;
|
||||||
pub mod game;
|
|
||||||
pub mod profile;
|
pub mod profile;
|
||||||
pub mod refresh;
|
pub mod refresh;
|
||||||
pub mod reply;
|
pub mod reply;
|
||||||
@ -45,16 +37,10 @@ pub mod repost;
|
|||||||
pub mod session;
|
pub mod session;
|
||||||
pub mod timeline_author;
|
pub mod timeline_author;
|
||||||
pub mod token;
|
pub mod token;
|
||||||
pub mod feed_get;
|
|
||||||
pub mod feed_watch;
|
|
||||||
pub mod delete_record;
|
|
||||||
|
|
||||||
fn main() {
|
fn main() {
|
||||||
let args: Vec<String> = env::args().collect();
|
let args: Vec<String> = env::args().collect();
|
||||||
let app = App::new(env!("CARGO_PKG_NAME"))
|
let app = App::new(env!("CARGO_PKG_NAME"))
|
||||||
.author(env!("CARGO_PKG_AUTHORS"))
|
|
||||||
.version(env!("CARGO_PKG_VERSION"))
|
|
||||||
.description(env!("CARGO_PKG_DESCRIPTION"))
|
|
||||||
.command(
|
.command(
|
||||||
Command::new("ai")
|
Command::new("ai")
|
||||||
.alias("a")
|
.alias("a")
|
||||||
@ -73,26 +59,6 @@ fn main() {
|
|||||||
Flag::new("admin", FlagType::String)
|
Flag::new("admin", FlagType::String)
|
||||||
.alias("a"),
|
.alias("a"),
|
||||||
)
|
)
|
||||||
.flag(
|
|
||||||
Flag::new("feed", FlagType::String)
|
|
||||||
.alias("f"),
|
|
||||||
)
|
|
||||||
)
|
|
||||||
.command(
|
|
||||||
Command::new("feed_watch")
|
|
||||||
.action(feed_watch)
|
|
||||||
.flag(
|
|
||||||
Flag::new("url", FlagType::String)
|
|
||||||
.alias("u"),
|
|
||||||
)
|
|
||||||
.flag(
|
|
||||||
Flag::new("tag", FlagType::String)
|
|
||||||
.alias("t"),
|
|
||||||
)
|
|
||||||
.flag(
|
|
||||||
Flag::new("debug", FlagType::Bool)
|
|
||||||
.alias("d"),
|
|
||||||
)
|
|
||||||
)
|
)
|
||||||
.command(
|
.command(
|
||||||
Command::new("follow_all")
|
Command::new("follow_all")
|
||||||
@ -129,12 +95,6 @@ fn main() {
|
|||||||
.alias("t")
|
.alias("t")
|
||||||
.action(timeline),
|
.action(timeline),
|
||||||
)
|
)
|
||||||
.command(
|
|
||||||
Command::new("feed")
|
|
||||||
.description("feed <feed-uri>")
|
|
||||||
.alias("f")
|
|
||||||
.action(feed)
|
|
||||||
)
|
|
||||||
.command(
|
.command(
|
||||||
Command::new("did")
|
Command::new("did")
|
||||||
.description("did <handle>")
|
.description("did <handle>")
|
||||||
@ -150,170 +110,6 @@ fn main() {
|
|||||||
.alias("l"),
|
.alias("l"),
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
.command(
|
|
||||||
Command::new("delete")
|
|
||||||
.description("d <rkey> -c <collection>")
|
|
||||||
.alias("d")
|
|
||||||
.action(delete)
|
|
||||||
.flag(
|
|
||||||
Flag::new("col", FlagType::String)
|
|
||||||
.alias("c"),
|
|
||||||
)
|
|
||||||
)
|
|
||||||
.command(
|
|
||||||
Command::new("card")
|
|
||||||
.description("-v <at://verify> -i <int:id> -p <int:cp> -r <int:rank> -c <collection> -a <author> -img <link> -rare <normal>")
|
|
||||||
.action(card)
|
|
||||||
.flag(
|
|
||||||
Flag::new("id", FlagType::Int)
|
|
||||||
.alias("i"),
|
|
||||||
)
|
|
||||||
.flag(
|
|
||||||
Flag::new("cp", FlagType::Int)
|
|
||||||
.alias("p"),
|
|
||||||
)
|
|
||||||
.flag(
|
|
||||||
Flag::new("rank", FlagType::Int)
|
|
||||||
.alias("r"),
|
|
||||||
)
|
|
||||||
.flag(
|
|
||||||
Flag::new("rare", FlagType::Int)
|
|
||||||
)
|
|
||||||
.flag(
|
|
||||||
Flag::new("col", FlagType::String)
|
|
||||||
.alias("c"),
|
|
||||||
)
|
|
||||||
.flag(
|
|
||||||
Flag::new("author", FlagType::String)
|
|
||||||
.alias("a"),
|
|
||||||
)
|
|
||||||
.flag(
|
|
||||||
Flag::new("verify", FlagType::String)
|
|
||||||
.alias("v"),
|
|
||||||
)
|
|
||||||
.flag(
|
|
||||||
Flag::new("img", FlagType::String)
|
|
||||||
)
|
|
||||||
)
|
|
||||||
.command(
|
|
||||||
Command::new("card-verify")
|
|
||||||
.description("<at://verify> -c <collection> -i <id> -p <cp> -r <rank> -rare <normal> -H <syui.ai> -d <did>")
|
|
||||||
.action(card_verify)
|
|
||||||
.flag(
|
|
||||||
Flag::new("col", FlagType::String)
|
|
||||||
.alias("c"),
|
|
||||||
)
|
|
||||||
.flag(
|
|
||||||
Flag::new("id", FlagType::Int)
|
|
||||||
.alias("i"),
|
|
||||||
)
|
|
||||||
.flag(
|
|
||||||
Flag::new("cp", FlagType::Int)
|
|
||||||
.alias("p"),
|
|
||||||
)
|
|
||||||
.flag(
|
|
||||||
Flag::new("rank", FlagType::Int)
|
|
||||||
.alias("r"),
|
|
||||||
)
|
|
||||||
.flag(
|
|
||||||
Flag::new("rare", FlagType::String)
|
|
||||||
)
|
|
||||||
.flag(
|
|
||||||
Flag::new("handle", FlagType::String)
|
|
||||||
.alias("H"),
|
|
||||||
)
|
|
||||||
.flag(
|
|
||||||
Flag::new("did", FlagType::String)
|
|
||||||
.alias("did"),
|
|
||||||
)
|
|
||||||
)
|
|
||||||
.command(
|
|
||||||
Command::new("game")
|
|
||||||
.description("a <at://yui.syui.ai/ai.syui.game.user/username>")
|
|
||||||
.action(game)
|
|
||||||
.flag(
|
|
||||||
Flag::new("col", FlagType::String)
|
|
||||||
.alias("c"),
|
|
||||||
)
|
|
||||||
.flag(
|
|
||||||
Flag::new("account", FlagType::String)
|
|
||||||
.alias("a"),
|
|
||||||
)
|
|
||||||
)
|
|
||||||
.command(
|
|
||||||
Command::new("game-login")
|
|
||||||
.description("l <bool> -u <username> -c <collection>")
|
|
||||||
.action(game_login)
|
|
||||||
.flag(
|
|
||||||
Flag::new("col", FlagType::String)
|
|
||||||
.alias("c"),
|
|
||||||
)
|
|
||||||
.flag(
|
|
||||||
Flag::new("login", FlagType::Bool)
|
|
||||||
.alias("l"),
|
|
||||||
)
|
|
||||||
.flag(
|
|
||||||
Flag::new("username", FlagType::String)
|
|
||||||
.alias("u"),
|
|
||||||
)
|
|
||||||
)
|
|
||||||
.command(
|
|
||||||
Command::new("game-user")
|
|
||||||
.description("-chara ai -l 20240101 -ten 0 --lv 0 --exp 0 --hp 0 --rank 0 --mode 0 --attach 0 --critical 0 --critical_d 0")
|
|
||||||
.action(game_user)
|
|
||||||
.flag(
|
|
||||||
Flag::new("username", FlagType::String)
|
|
||||||
.alias("u"),
|
|
||||||
)
|
|
||||||
.flag(
|
|
||||||
Flag::new("col", FlagType::String)
|
|
||||||
.alias("c"),
|
|
||||||
)
|
|
||||||
.flag(
|
|
||||||
Flag::new("did", FlagType::String)
|
|
||||||
.alias("d"),
|
|
||||||
)
|
|
||||||
.flag(
|
|
||||||
Flag::new("handle", FlagType::String)
|
|
||||||
.alias("H"),
|
|
||||||
)
|
|
||||||
.flag(
|
|
||||||
Flag::new("character", FlagType::String)
|
|
||||||
.alias("chara"),
|
|
||||||
)
|
|
||||||
.flag(
|
|
||||||
Flag::new("aiten", FlagType::Int)
|
|
||||||
.alias("ten"),
|
|
||||||
)
|
|
||||||
.flag(
|
|
||||||
Flag::new("limit", FlagType::Int)
|
|
||||||
.alias("l"),
|
|
||||||
)
|
|
||||||
.flag(
|
|
||||||
Flag::new("lv", FlagType::Int)
|
|
||||||
)
|
|
||||||
.flag(
|
|
||||||
Flag::new("hp", FlagType::Int)
|
|
||||||
)
|
|
||||||
.flag(
|
|
||||||
Flag::new("attach", FlagType::Int)
|
|
||||||
)
|
|
||||||
.flag(
|
|
||||||
Flag::new("exp", FlagType::Int)
|
|
||||||
)
|
|
||||||
.flag(
|
|
||||||
Flag::new("critical", FlagType::Int)
|
|
||||||
)
|
|
||||||
.flag(
|
|
||||||
Flag::new("critical_d", FlagType::Int)
|
|
||||||
)
|
|
||||||
.flag(
|
|
||||||
Flag::new("rank", FlagType::Int)
|
|
||||||
)
|
|
||||||
.flag(
|
|
||||||
Flag::new("mode", FlagType::Int)
|
|
||||||
)
|
|
||||||
)
|
|
||||||
.command(
|
.command(
|
||||||
Command::new("like")
|
Command::new("like")
|
||||||
.description("like <cid> -u <uri>")
|
.description("like <cid> -u <uri>")
|
||||||
@ -394,10 +190,6 @@ fn main() {
|
|||||||
Flag::new("post", FlagType::String)
|
Flag::new("post", FlagType::String)
|
||||||
.alias("p"),
|
.alias("p"),
|
||||||
)
|
)
|
||||||
.flag(
|
|
||||||
Flag::new("col", FlagType::String)
|
|
||||||
.alias("c"),
|
|
||||||
)
|
|
||||||
)
|
)
|
||||||
.command(
|
.command(
|
||||||
Command::new("follow")
|
Command::new("follow")
|
||||||
@ -479,14 +271,6 @@ fn bot(c: &Context) {
|
|||||||
refresh(c);
|
refresh(c);
|
||||||
loop {
|
loop {
|
||||||
c_bot(c);
|
c_bot(c);
|
||||||
c_bot_feed(c);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
fn feed_watch(c: &Context) {
|
|
||||||
refresh(c);
|
|
||||||
loop {
|
|
||||||
c_feed_watch(c);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -522,12 +306,15 @@ fn refresh(_c: &Context) {
|
|||||||
let session = session::get_request().await;
|
let session = session::get_request().await;
|
||||||
if session == "err" {
|
if session == "err" {
|
||||||
let res = refresh::post_request().await;
|
let res = refresh::post_request().await;
|
||||||
|
println!("{}", res);
|
||||||
if res == "err" {
|
if res == "err" {
|
||||||
let m = data_toml(&"handle");
|
let m = data_toml(&"handle");
|
||||||
let p = data_toml(&"password");
|
let p = data_toml(&"password");
|
||||||
let s = data_toml(&"host");
|
let s = data_toml(&"host");
|
||||||
|
println!("handle:{}, pass:{}, host:{}", m, p, s);
|
||||||
let res = token::post_request(m.to_string(), p.to_string(), s.to_string()).await;
|
let res = token::post_request(m.to_string(), p.to_string(), s.to_string()).await;
|
||||||
w_cfg(&s, &res, &p);
|
w_cfg(&s, &res, &p);
|
||||||
|
println!("res:{}", res);
|
||||||
} else {
|
} else {
|
||||||
w_refresh(&res);
|
w_refresh(&res);
|
||||||
}
|
}
|
||||||
@ -547,22 +334,6 @@ fn notify(c: &Context) {
|
|||||||
return res;
|
return res;
|
||||||
}
|
}
|
||||||
|
|
||||||
fn feed(c: &Context) {
|
|
||||||
refresh(c);
|
|
||||||
let feed_d = "at://did:plc:4hqjfn7m6n5hno3doamuhgef/app.bsky.feed.generator/cmd".to_string();
|
|
||||||
let h = async {
|
|
||||||
if c.args.len() == 0 {
|
|
||||||
let j = feed_get::get_request(feed_d).await;
|
|
||||||
println!("{}", j);
|
|
||||||
} else {
|
|
||||||
let j = feed_get::get_request(c.args[0].to_string()).await;
|
|
||||||
println!("{}", j);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
let res = tokio::runtime::Runtime::new().unwrap().block_on(h);
|
|
||||||
return res;
|
|
||||||
}
|
|
||||||
|
|
||||||
fn did(c: &Context) {
|
fn did(c: &Context) {
|
||||||
refresh(c);
|
refresh(c);
|
||||||
let h = async {
|
let h = async {
|
||||||
@ -612,19 +383,6 @@ fn post(c: &Context) {
|
|||||||
return res;
|
return res;
|
||||||
}
|
}
|
||||||
|
|
||||||
fn delete(c: &Context) {
|
|
||||||
refresh(c);
|
|
||||||
let m = c.args[0].to_string();
|
|
||||||
let h = async {
|
|
||||||
if let Ok(col) = c.string_flag("col") {
|
|
||||||
let str = delete_record::post_request(m.to_string(), col);
|
|
||||||
println!("{}", str.await);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
let res = tokio::runtime::Runtime::new().unwrap().block_on(h);
|
|
||||||
return res;
|
|
||||||
}
|
|
||||||
|
|
||||||
fn like(c: &Context) {
|
fn like(c: &Context) {
|
||||||
refresh(c);
|
refresh(c);
|
||||||
let m = c.args[0].to_string();
|
let m = c.args[0].to_string();
|
||||||
@ -638,145 +396,6 @@ fn like(c: &Context) {
|
|||||||
return res;
|
return res;
|
||||||
}
|
}
|
||||||
|
|
||||||
async fn c_card(c: &Context) -> Result<(), Box<dyn std::error::Error>> {
|
|
||||||
//let m = c.args[0].to_string();
|
|
||||||
let author = c.string_flag("author").unwrap_or_else(|_| "syui".to_string());
|
|
||||||
let verify = c.string_flag("verify").unwrap_or_else(|_| "at://did:plc:4hqjfn7m6n5hno3doamuhgef/ai.syui.card.verify/3lagpvhppmd2q".to_string());
|
|
||||||
let col = c.string_flag("col").unwrap_or_else(|_| "ai.syui.card".to_string());
|
|
||||||
//let img = c.string_flag("img").unwrap_or_else(|_| "bafkreigvcjc46qtelpc4wsg7fwf6qktbi6a23ouqiupth2r37zhrn7wbza".to_string());
|
|
||||||
let id = c.int_flag("id")?.try_into()?;
|
|
||||||
let cp = c.int_flag("cp")?.try_into()?;
|
|
||||||
let rank = c.int_flag("rank")?.try_into()?;
|
|
||||||
let rare = c.string_flag("rare").unwrap_or_else(|_| "normal".to_string());
|
|
||||||
let str = post_card::post_request(verify, id, cp, rank, rare, col, author);
|
|
||||||
println!("{}", str.await);
|
|
||||||
Ok(())
|
|
||||||
}
|
|
||||||
|
|
||||||
fn card(c: &Context) {
|
|
||||||
refresh(c);
|
|
||||||
tokio::runtime::Runtime::new()
|
|
||||||
.unwrap()
|
|
||||||
.block_on(async {
|
|
||||||
if let Err(e) = c_card(c).await {
|
|
||||||
eprintln!("Error: {}", e);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
async fn c_card_verify(c: &Context) -> Result<(), Box<dyn std::error::Error>> {
|
|
||||||
let col = c.string_flag("col").unwrap_or_else(|_| "ai.syui.card.verify".to_string());
|
|
||||||
let img = c.string_flag("img").unwrap_or_else(|_| "bafkreigvcjc46qtelpc4wsg7fwf6qktbi6a23ouqiupth2r37zhrn7wbza".to_string());
|
|
||||||
let id = c.int_flag("id")?.try_into()?;
|
|
||||||
let cp = c.int_flag("cp")?.try_into()?;
|
|
||||||
let rank = c.int_flag("rank")?.try_into()?;
|
|
||||||
let rare = c.string_flag("rare").unwrap_or_else(|_| "normal".to_string());
|
|
||||||
let user_handle = c.string_flag("handle").unwrap_or_else(|_| "syui.ai".to_string());
|
|
||||||
let user_did = c.string_flag("did").unwrap_or_else(|_| "did:plc:uqzpqmrjnptsxezjx4xuh2mn".to_string());
|
|
||||||
|
|
||||||
//match id === 1 let img = "xxx";
|
|
||||||
let str = post_card_verify::post_request(col, img, id, cp, rank, rare, user_handle, user_did);
|
|
||||||
println!("{}", str.await);
|
|
||||||
Ok(())
|
|
||||||
}
|
|
||||||
|
|
||||||
fn card_verify(c: &Context) {
|
|
||||||
refresh(c);
|
|
||||||
tokio::runtime::Runtime::new()
|
|
||||||
.unwrap()
|
|
||||||
.block_on(async {
|
|
||||||
if let Err(e) = c_card_verify(c).await {
|
|
||||||
eprintln!("Error: {}", e);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
async fn c_game(c: &Context) -> Result<(), Box<dyn std::error::Error>> {
|
|
||||||
let account = c.string_flag("account").unwrap_or_else(|_| "at://did:plc:4hqjfn7m6n5hno3doamuhgef/ai.syui.game.user/syui".to_string());
|
|
||||||
let col = c.string_flag("col").unwrap_or_else(|_| "ai.syui.game".to_string());
|
|
||||||
let handle = data_toml(&"handle");
|
|
||||||
if handle == "syui.ai" {
|
|
||||||
let str = post_game::post_request(col, account);
|
|
||||||
println!("{}", str.await);
|
|
||||||
Ok(())
|
|
||||||
} else {
|
|
||||||
Err(Box::new(std::io::Error::new(std::io::ErrorKind::PermissionDenied, "Not authorized")))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
fn game(c: &Context) {
|
|
||||||
refresh(c);
|
|
||||||
tokio::runtime::Runtime::new()
|
|
||||||
.unwrap()
|
|
||||||
.block_on(async {
|
|
||||||
if let Err(e) = c_game(c).await {
|
|
||||||
eprintln!("Error: {}", e);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
async fn c_game_user(c: &Context) -> Result<(), Box<dyn std::error::Error>> {
|
|
||||||
let col = c.string_flag("col").unwrap_or_else(|_| "ai.syui.game.user".to_string());
|
|
||||||
let user_name = c.string_flag("username").unwrap_or_else(|_| "syui".to_string());
|
|
||||||
let user_handle = c.string_flag("handle").unwrap_or_else(|_| "syui.ai".to_string());
|
|
||||||
let user_did = c.string_flag("did").unwrap_or_else(|_| "did:plc:uqzpqmrjnptsxezjx4xuh2mn".to_string());
|
|
||||||
let chara = c.string_flag("character").unwrap_or_else(|_| "ai".to_string());
|
|
||||||
let limit = c.int_flag("limit")?.try_into()?;
|
|
||||||
let aiten = c.int_flag("aiten")?.try_into()?;
|
|
||||||
let lv = c.int_flag("lv")?.try_into()?;
|
|
||||||
let exp = c.int_flag("exp")?.try_into()?;
|
|
||||||
let hp = c.int_flag("hp")?.try_into()?;
|
|
||||||
let rank = c.int_flag("rank")?.try_into()?;
|
|
||||||
let mode = c.int_flag("mode")?.try_into()?;
|
|
||||||
let attach = c.int_flag("attach")?.try_into()?;
|
|
||||||
let critical = c.int_flag("critical")?.try_into()?;
|
|
||||||
let critical_d = c.int_flag("critical_d")?.try_into()?;
|
|
||||||
|
|
||||||
if data_toml(&"handle") == "yui.syui.ai" {
|
|
||||||
let str = post_game_user::post_request(col, user_name, user_did, user_handle, aiten, limit, chara, lv, exp, hp, rank, mode, attach, critical, critical_d);
|
|
||||||
println!("{}", str.await);
|
|
||||||
Ok(())
|
|
||||||
} else {
|
|
||||||
Err(Box::new(std::io::Error::new(std::io::ErrorKind::PermissionDenied, "Not authorized")))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
fn game_user(c: &Context) {
|
|
||||||
refresh(c);
|
|
||||||
tokio::runtime::Runtime::new()
|
|
||||||
.unwrap()
|
|
||||||
.block_on(async {
|
|
||||||
if let Err(e) = c_game_user(c).await {
|
|
||||||
eprintln!("Error: {}", e);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
async fn c_game_login(c: &Context) -> Result<(), Box<dyn std::error::Error>> {
|
|
||||||
let col = c.string_flag("col").unwrap_or_else(|_| "ai.syui.game.login".to_string());
|
|
||||||
let user_name = c.string_flag("username").unwrap_or_else(|_| "syui".to_string());
|
|
||||||
let account = "at://did:plc:4hqjfn7m6n5hno3doamuhgef/ai.syui.game.user/".to_string() + &user_name;
|
|
||||||
let login = c.bool_flag("login");
|
|
||||||
if data_toml(&"handle") == "yui.syui.ai" {
|
|
||||||
let str = post_game_login::post_request(col, user_name, login, account);
|
|
||||||
println!("{}", str.await);
|
|
||||||
Ok(())
|
|
||||||
} else {
|
|
||||||
Err(Box::new(std::io::Error::new(std::io::ErrorKind::PermissionDenied, "Not authorized")))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
fn game_login(c: &Context) {
|
|
||||||
refresh(c);
|
|
||||||
tokio::runtime::Runtime::new()
|
|
||||||
.unwrap()
|
|
||||||
.block_on(async {
|
|
||||||
if let Err(e) = c_game_login(c).await {
|
|
||||||
eprintln!("Error: {}", e);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
fn repost(c: &Context) {
|
fn repost(c: &Context) {
|
||||||
refresh(c);
|
refresh(c);
|
||||||
let m = c.args[0].to_string();
|
let m = c.args[0].to_string();
|
||||||
@ -831,7 +450,6 @@ fn mention(c: &Context) {
|
|||||||
let h = async {
|
let h = async {
|
||||||
let str = profile::get_request(m.to_string()).await;
|
let str = profile::get_request(m.to_string()).await;
|
||||||
let profile: ProfileIdentityResolve = serde_json::from_str(&str).unwrap();
|
let profile: ProfileIdentityResolve = serde_json::from_str(&str).unwrap();
|
||||||
let col = c.string_flag("col").unwrap_or_else(|_| "app.bsky.feed.post".to_string());
|
|
||||||
let udid = profile.did;
|
let udid = profile.did;
|
||||||
let handle = m.to_string();
|
let handle = m.to_string();
|
||||||
let at = "@".to_owned() + &handle;
|
let at = "@".to_owned() + &handle;
|
||||||
@ -839,7 +457,6 @@ fn mention(c: &Context) {
|
|||||||
let s = 0;
|
let s = 0;
|
||||||
if let Ok(post) = c.string_flag("post") {
|
if let Ok(post) = c.string_flag("post") {
|
||||||
let str = mention::post_request(
|
let str = mention::post_request(
|
||||||
col,
|
|
||||||
post.to_string(),
|
post.to_string(),
|
||||||
at.to_string(),
|
at.to_string(),
|
||||||
udid.to_string(),
|
udid.to_string(),
|
||||||
|
|||||||
@ -5,13 +5,13 @@ use crate::url;
|
|||||||
use iso8601_timestamp::Timestamp;
|
use iso8601_timestamp::Timestamp;
|
||||||
use serde_json::json;
|
use serde_json::json;
|
||||||
|
|
||||||
pub async fn post_request(col: String, text: String, at: String, udid: String, s: i32, e: i32) -> String {
|
pub async fn post_request(text: String, at: String, udid: String, s: i32, e: i32) -> String {
|
||||||
let token = data_refresh(&"access");
|
let token = data_refresh(&"access");
|
||||||
let did = data_toml(&"did");
|
let did = data_toml(&"did");
|
||||||
let handle = data_toml(&"handle");
|
let handle = data_toml(&"handle");
|
||||||
|
|
||||||
let url = url(&"record_create");
|
let url = url(&"record_create");
|
||||||
//let col = "app.bsky.feed.post".to_string();
|
let col = "app.bsky.feed.post".to_string();
|
||||||
|
|
||||||
let d = Timestamp::now_utc();
|
let d = Timestamp::now_utc();
|
||||||
let d = d.to_string();
|
let d = d.to_string();
|
||||||
@ -22,7 +22,7 @@ pub async fn post_request(col: String, text: String, at: String, udid: String, s
|
|||||||
"collection": col.to_string(),
|
"collection": col.to_string(),
|
||||||
"record": {
|
"record": {
|
||||||
"text": at.to_string() + &" ".to_string() + &text.to_string(),
|
"text": at.to_string() + &" ".to_string() + &text.to_string(),
|
||||||
"$type": col.to_string(),
|
"$type": "app.bsky.feed.post",
|
||||||
"createdAt": d.to_string(),
|
"createdAt": d.to_string(),
|
||||||
"facets": [
|
"facets": [
|
||||||
{
|
{
|
||||||
|
|||||||
@ -33,7 +33,7 @@ pub async fn post_request(prompt: String) -> String {
|
|||||||
";
|
";
|
||||||
|
|
||||||
let post = Some(json!({
|
let post = Some(json!({
|
||||||
"model": "gpt-4o-mini",
|
"model": "gpt-3.5-turbo",
|
||||||
"messages": [
|
"messages": [
|
||||||
{"role": "system", "content": &setting.to_string()},
|
{"role": "system", "content": &setting.to_string()},
|
||||||
{"role": "user", "content": &prompt.to_string()},
|
{"role": "user", "content": &prompt.to_string()},
|
||||||
|
|||||||
@ -9,14 +9,13 @@ case $OSTYPE in
|
|||||||
esac
|
esac
|
||||||
d=${0:a:h}
|
d=${0:a:h}
|
||||||
|
|
||||||
source $d/env.zsh
|
source $d/env
|
||||||
source $d/refresh.zsh
|
source $d/refresh.zsh
|
||||||
source $d/token.zsh
|
source $d/token.zsh
|
||||||
source $d/reply.zsh
|
source $d/reply.zsh
|
||||||
source $d/notify.zsh
|
source $d/notify.zsh
|
||||||
source $d/notify_cid.zsh
|
source $d/notify_cid.zsh
|
||||||
source $d/cron.zsh
|
source $d/cron.zsh
|
||||||
source $d/feed.zsh
|
|
||||||
|
|
||||||
case $1 in
|
case $1 in
|
||||||
refresh|r)
|
refresh|r)
|
||||||
@ -37,7 +36,4 @@ case $1 in
|
|||||||
cid)
|
cid)
|
||||||
cid
|
cid
|
||||||
;;
|
;;
|
||||||
feed)
|
|
||||||
feed
|
|
||||||
;;
|
|
||||||
esac
|
esac
|
||||||
|
|||||||
@ -1,7 +1,7 @@
|
|||||||
function cron() {
|
function cron() {
|
||||||
t=`docker ps |grep aios|grep R`
|
t=`docker ps |grep aios|grep Up`
|
||||||
if [ -z "$t" ];then
|
if [ -z "$t" ];then
|
||||||
exit
|
docker compose up -d
|
||||||
fi
|
fi
|
||||||
docker compose up -d
|
exit
|
||||||
}
|
}
|
||||||
|
|||||||
@ -1,4 +1,3 @@
|
|||||||
#!/bin/zsh
|
#!/bin/zsh
|
||||||
|
|
||||||
#ai l $HANDLE -p $PASSWORD -s $HOST
|
ai l $HANDLE -p $PASSWORD -s $HOST && ai bot -a $ADMIN
|
||||||
ai bot -a $ADMIN
|
|
||||||
|
|||||||
@ -1,5 +0,0 @@
|
|||||||
function feed(){
|
|
||||||
token=`cat ~/.config/ai/token.json|jq -r .accessJwt`
|
|
||||||
url=at://did:plc:4hqjfn7m6n5hno3doamuhgef/app.bsky.feed.generator/cmd
|
|
||||||
curl -sL "https://public.api.bsky.app/xrpc/app.bsky.feed.getFeed?feed=$url" -H "Authorization: Bearer $token"
|
|
||||||
}
|
|
||||||
Reference in New Issue
Block a user