Compare commits

..

3 Commits

Author SHA1 Message Date
d6a2c975e9 fix
All checks were successful
Gitea Actions Demo / Explore-Gitea-Actions (push) Successful in 4s
2024-04-13 05:32:45 +09:00
38a14cd0d7 fix
All checks were successful
Gitea Actions Demo / Explore-Gitea-Actions (push) Successful in 4s
2024-04-13 05:31:39 +09:00
3b2c9eb1a2 add bot custom feed
All checks were successful
Gitea Actions Demo / Explore-Gitea-Actions (push) Successful in 4s
2024-04-13 05:24:34 +09:00
25 changed files with 55 additions and 1079 deletions

2
.gitignore vendored
View File

@ -1,6 +1,6 @@
Cargo.lock Cargo.lock
target target
#*.json *.json
*.DS_Store *.DS_Store
**.DS_Store **.DS_Store
scpt/json/ scpt/json/

View File

@ -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 = "*"

View File

@ -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 .

View File

@ -63,19 +63,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 +88,7 @@ $ cargo install --force cargo-make
$ cargo make build $ cargo make build
``` ```
### docker ### docker
> .env > .env
@ -107,38 +104,3 @@ ADMIN=syui.syu.is
$ 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
```

View File

@ -18,9 +18,3 @@ echo $uri
```sh ```sh
$ git clone https://github.com/bluesky-social/feed-generator $ 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
```

View File

@ -19,7 +19,8 @@ export class FirehoseSubscription extends FirehoseSubscriptionBase {
const postsToDelete = ops.posts.deletes.map((del) => del.uri) const postsToDelete = ops.posts.deletes.map((del) => del.uri)
const postsToCreate = ops.posts.creates const postsToCreate = ops.posts.creates
.filter((create) => { .filter((create) => {
return create.record.text.match('^/[a-z]') || create.record.text.match('^@ai ') || create.record.text.match('/ai '); // only alf-related posts
return create.record.text.match('^/[a-z]');
//return create.record.text.toLowerCase().includes('alf') //return create.record.text.toLowerCase().includes('alf')
}) })
.map((create) => { .map((create) => {

View File

@ -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 .
```

View File

@ -72,32 +72,12 @@ $ curl -sLO https://raw.githubusercontent.com/rdmurphy/atproto-openapi-types/mai
$ .config/ai/scpt/test/pds.zsh e $ .config/ai/scpt/test/pds.zsh e
``` ```
## cmt ## manga
blogなどにblueskyアカウントのpostを表示します。
以下でbotがblogのコメントシステムを開きます。
```sh ```sh
@yui.syui.ai /comment https://syui.ai/blog/post/2024/04/25/bluesky/ $ ai bot --manga_uri at://did:plc:dconvttcori3mrh2wrmehvwt/app.bsky.feed.post/3kp4zdnlo5s2j
``` ```
開いた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>&mdash; 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 ```json
[ [
{ {
@ -185,6 +165,10 @@ blogなどにblueskyアカウントのpostを表示します。
] ]
``` ```
```sh
$ ai bot -a syui.ai --manga_uri at://did:plc:4hqjfn7m6n5hno3doamuhgef/app.bsky.feed.post/3kp5qn72s232q
```
```json ```json
{ {
"uri": "at://did:plc:uqzpqmrjnptsxezjx4xuh2mn/app.bsky.feed.post/3kp5qniyzm42h", "uri": "at://did:plc:uqzpqmrjnptsxezjx4xuh2mn/app.bsky.feed.post/3kp5qniyzm42h",

View File

@ -46,7 +46,6 @@ pub fn c_bot(c: &Context) {
cid_root = &n[i].record.reply.as_ref().unwrap().root.cid; cid_root = &n[i].record.reply.as_ref().unwrap().root.cid;
uri_root = &n[i].record.reply.as_ref().unwrap().root.uri; uri_root = &n[i].record.reply.as_ref().unwrap().root.uri;
} }
let check_uri_comment = w_cid(uri_root.to_string(), log_file(&"c1"), false);
let mut text = ""; let mut text = "";
if !n[i].record.text.is_none() { if !n[i].record.text.is_none() {
@ -65,11 +64,7 @@ pub fn c_bot(c: &Context) {
let mut prompt = "".to_string(); let mut prompt = "".to_string();
let mut prompt_sub = "".to_string(); let mut prompt_sub = "".to_string();
let mut prompt_chat = "".to_string(); let mut prompt_chat = "".to_string();
if reason == "mention" { if reason == "mention" {
if vec.len() == 1 {
return;
}
com = vec[1].trim().to_string(); com = vec[1].trim().to_string();
prompt = vec[2..].join(" "); prompt = vec[2..].join(" ");
prompt_chat = vec[1..].join(" "); prompt_chat = vec[1..].join(" ");
@ -101,6 +96,11 @@ pub fn c_bot(c: &Context) {
admin = c.string_flag("admin").unwrap(); admin = c.string_flag("admin").unwrap();
} }
let mut manga_uri = "".to_string();
if c.string_flag("manga_uri").is_ok() {
manga_uri = c.string_flag("manga_uri").unwrap();
}
let mut avatar = "".to_string(); let mut avatar = "".to_string();
if let Some(v) = &n[i].author.avatar { if let Some(v) = &n[i].author.avatar {
avatar = v.to_string(); avatar = v.to_string();
@ -110,7 +110,7 @@ pub fn c_bot(c: &Context) {
|| check_cid_run == false && { reason == "mention" || reason == "reply" } || check_cid_run == false && { reason == "mention" || reason == "reply" }
{ {
w_cid(cid.to_string(), log_file(&"n2"), true); w_cid(cid.to_string(), log_file(&"n2"), true);
if com == "did" || com == "/did" { if com == "did" {
let link = "https://plc.directory/".to_owned() + &did + &"/log"; let link = "https://plc.directory/".to_owned() + &did + &"/log";
let s = 0; let s = 0;
let e = link.chars().count(); let e = link.chars().count();
@ -395,134 +395,6 @@ pub fn c_bot(c: &Context) {
println!("{}", str_rep); println!("{}", str_rep);
w_cid(cid.to_string(), log_file(&"n1"), true); w_cid(cid.to_string(), log_file(&"n1"), true);
} }
} else if com == "planet" || com == "/planet" {
let output = Command::new(data_scpt(&"ai"))
.arg(&"atproto").arg(&"planet")
.arg(&handle)
.arg(&did)
.arg(&cid)
.arg(&uri)
.arg(&cid_root)
.arg(&uri_root)
.arg(&host)
.arg(&prompt)
.arg(&prompt_sub)
.output()
.expect("zsh");
let d = String::from_utf8_lossy(&output.stdout);
let dd = "\n".to_owned() + &d.to_string();
let text_limit = c_char(dd);
handlev = d.lines().collect::<Vec<_>>()[0].to_string();
link = "https://card.syui.ai/".to_owned() + &handlev;
println!("{}", e);
e = link.chars().count();
if text_limit.len() > 3 {
let str_rep = reply_link::post_request(
text_limit.to_string(),
link.to_string(),
s,
e.try_into().unwrap(),
cid.to_string(),
uri.to_string(),
cid_root.to_string(),
uri_root.to_string(),
)
.await;
println!("{}", str_rep);
w_cid(cid.to_string(), log_file(&"n1"), true);
}
} else if com == "game" || com == "/game" {
let output = Command::new(data_scpt(&"ai"))
.arg(&"atproto").arg(&"game")
.arg(&handle)
.arg(&did)
.arg(&cid)
.arg(&uri)
.arg(&cid_root)
.arg(&uri_root)
.arg(&host)
.arg(&prompt)
.arg(&prompt_sub)
.output()
.expect("zsh");
let d = String::from_utf8_lossy(&output.stdout);
let dd = "\n".to_owned() + &d.to_string();
let text_limit = c_char(dd);
handlev = d.lines().collect::<Vec<_>>()[0].to_string();
link = "https://card.syui.ai/".to_owned() + &handlev;
println!("{}", e);
e = link.chars().count();
if text_limit.len() > 3 {
let str_rep = reply_link::post_request(
text_limit.to_string(),
link.to_string(),
s,
e.try_into().unwrap(),
cid.to_string(),
uri.to_string(),
cid_root.to_string(),
uri_root.to_string(),
)
.await;
println!("{}", str_rep);
w_cid(cid.to_string(), log_file(&"n1"), true);
}
} else if com == "quiz" || com == "/quiz" {
println!("admin:{}", admin);
let output = Command::new(data_scpt(&"ai"))
.arg(&"atproto").arg(&"quiz")
.arg(&handle)
.arg(&did)
.arg(&cid)
.arg(&uri)
.arg(&cid_root)
.arg(&uri_root)
.arg(&host)
.arg(&prompt)
.arg(&prompt_sub)
.output()
.expect("zsh");
let d = String::from_utf8_lossy(&output.stdout);
let d = d.to_string();
let text_limit = c_char(d);
let str_rep = reply::post_request(
text_limit.to_string(),
cid.to_string(),
uri.to_string(),
cid_root.to_string(),
uri_root.to_string(),
)
.await;
println!("{}", str_rep);
w_cid(cid.to_string(), log_file(&"n1"), true);
} else if check_uri_comment == true {
println!("admin:{}", admin);
let output = Command::new(data_scpt(&"ai"))
.arg(&"atproto").arg(&"comment")
.arg(&handle)
.arg(&did)
.arg(&cid)
.arg(&uri)
.arg(&cid_root)
.arg(&uri_root)
.arg(&host)
.arg(&avatar)
.arg(&prompt_chat)
.output()
.expect("zsh");
let d = String::from_utf8_lossy(&output.stdout);
let d = d.to_string();
let text_limit = c_char(d);
let str_rep = reply::post_request(
text_limit.to_string(),
cid.to_string(),
uri.to_string(),
cid_root.to_string(),
uri_root.to_string(),
)
.await;
println!("{}", str_rep);
w_cid(cid.to_string(), log_file(&"n1"), true);
} else if { com == "sh" || com == "/sh" } && handle == &admin { } else if { com == "sh" || com == "/sh" } && handle == &admin {
println!("admin:{}", admin); println!("admin:{}", admin);
let output = Command::new(data_scpt(&"ai")) let output = Command::new(data_scpt(&"ai"))
@ -551,7 +423,7 @@ pub fn c_bot(c: &Context) {
.await; .await;
println!("{}", str_rep); println!("{}", str_rep);
w_cid(cid.to_string(), log_file(&"n1"), true); w_cid(cid.to_string(), log_file(&"n1"), true);
} else if { com == "mitractl" || com == "/mitractl" } && handle == &admin { } else if com == "mitractl" && handle == &admin {
println!("admin:{}", admin); println!("admin:{}", admin);
let output = Command::new(data_scpt(&"ai")) let output = Command::new(data_scpt(&"ai"))
.arg(&"atproto").arg(&"mitra") .arg(&"atproto").arg(&"mitra")
@ -586,10 +458,10 @@ pub fn c_bot(c: &Context) {
println!("{}", str_rep); println!("{}", str_rep);
w_cid(cid.to_string(), log_file(&"n1"), true); w_cid(cid.to_string(), log_file(&"n1"), true);
} }
} else if { com == "comment" || com == "/comment" } && { handle == &admin || handle == "yui.bsky.social" } && check_uri_comment == false { } else if uri_root == &manga_uri {
println!("admin:{}", admin); println!("manga_uri:{}", manga_uri);
let output = Command::new(data_scpt(&"ai")) let output = Command::new(data_scpt(&"ai"))
.arg(&"atproto").arg(&"comment") .arg(&"atproto").arg(&"manga")
.arg(&handle) .arg(&handle)
.arg(&did) .arg(&did)
.arg(&cid) .arg(&cid)
@ -614,7 +486,6 @@ pub fn c_bot(c: &Context) {
.await; .await;
println!("{}", str_rep); println!("{}", str_rep);
w_cid(cid.to_string(), log_file(&"n1"), true); w_cid(cid.to_string(), log_file(&"n1"), true);
w_cid(uri_root.to_string(), log_file(&"c1"), true);
} else { } else {
// openai // openai
let str_openai = openai::post_request(prompt_chat.to_string()).await; let str_openai = openai::post_request(prompt_chat.to_string()).await;
@ -646,11 +517,10 @@ pub fn c_bot_feed(c: &Context) {
feed = c.string_flag("feed").unwrap(); feed = c.string_flag("feed").unwrap();
} }
let h = async { let h = async {
let notify = feed_get::get_request(feed).await; let mut notify = feed_get::get_request(feed).await;
if notify == "err" { if notify == "err" {
return; refresh(c);
//refresh(c); notify = feed_get::get_request("at://did:plc:4hqjfn7m6n5hno3doamuhgef/app.bsky.feed.generator/cmd".to_string()).await;
//notify = feed_get::get_request("at://did:plc:4hqjfn7m6n5hno3doamuhgef/app.bsky.feed.generator/cmd".to_string()).await;
} }
let timeline: Timeline = serde_json::from_str(&notify).unwrap(); let timeline: Timeline = serde_json::from_str(&notify).unwrap();
let n = timeline.feed; let n = timeline.feed;
@ -667,18 +537,11 @@ pub fn c_bot_feed(c: &Context) {
let uri_root = uri; let uri_root = uri;
let check_cid = w_cid(cid.to_string(), log_file(&"n1"), false); let check_cid = w_cid(cid.to_string(), log_file(&"n1"), false);
let check_cid_run = w_cid(cid.to_string(), log_file(&"n2"), false); let check_cid_run = w_cid(cid.to_string(), log_file(&"n2"), false);
//let mut avatar = "".to_string();
//if let Some(v) = &n[i].post.author.avatar {
// avatar = v.to_string();
//}
let mut text = ""; let mut text = "";
if !n[i].post.record.text.is_none() { if !n[i].post.record.text.is_none() {
text = &n[i].post.record.text.as_ref().unwrap(); text = &n[i].post.record.text.as_ref().unwrap();
} }
//let mut reason = false;
//if !n[i].post.record.reply.is_none() {
// reason = true;
//}
let vec: Vec<&str> = text.split_whitespace().collect(); let vec: Vec<&str> = text.split_whitespace().collect();
let handlev: Vec<&str> = handle.split('.').collect(); let handlev: Vec<&str> = handle.split('.').collect();
let mut handlev = handlev[0].trim().to_string(); let mut handlev = handlev[0].trim().to_string();
@ -687,21 +550,12 @@ pub fn c_bot_feed(c: &Context) {
let mut link = "https://card.syui.ai/".to_owned() + &handlev; let mut link = "https://card.syui.ai/".to_owned() + &handlev;
let s = 0; let s = 0;
let mut e = link.chars().count(); let mut e = link.chars().count();
let com = vec[0].trim().to_string();
let mut prompt = "".to_string();
let mut prompt_sub = "".to_string(); let mut prompt_sub = "".to_string();
let mut prompt_chat = "".to_string(); let com = vec[0].trim().to_string();
let mut prompt_all = "".to_string(); let prompt = vec[1..].join(" ");
if vec.len() > 1 {
if com == "@ai" || com == "/ai" { prompt_sub = vec[2..].join(" ");
prompt_chat = vec[1..].join(" ");
} else {
prompt = vec[1..].join(" ");
prompt_all = vec[0..].join(" ");
if vec.len() > 1 {
prompt_sub = vec[2..].join(" ");
}
} }
if prompt.is_empty() == false || com.is_empty() == false { if prompt.is_empty() == false || com.is_empty() == false {
@ -722,7 +576,7 @@ pub fn c_bot_feed(c: &Context) {
|| check_cid_run == false || check_cid_run == false
{ {
w_cid(cid.to_string(), log_file(&"n2"), true); w_cid(cid.to_string(), log_file(&"n2"), true);
if com == "did" || com == "/did" { if com == "did" {
let link = "https://plc.directory/".to_owned() + &did + &"/log"; let link = "https://plc.directory/".to_owned() + &did + &"/log";
let s = 0; let s = 0;
let e = link.chars().count(); let e = link.chars().count();
@ -775,9 +629,9 @@ pub fn c_bot_feed(c: &Context) {
.output() .output()
.expect("zsh"); .expect("zsh");
w_cid(cid.to_string(), log_file(&"n1"), true); w_cid(cid.to_string(), log_file(&"n1"), true);
} else if com.contains("/") == true } else if com.contains("") == true
|| com.contains("/うらない") == true || com.contains("うらない") == true
|| com.contains("/うらなって") == true || com.contains("うらなって") == true
{ {
let _output = Command::new(data_scpt(&"ai")) let _output = Command::new(data_scpt(&"ai"))
.arg(&"atproto").arg(&"fortune") .arg(&"atproto").arg(&"fortune")
@ -793,26 +647,6 @@ pub fn c_bot_feed(c: &Context) {
.output() .output()
.expect("zsh"); .expect("zsh");
w_cid(cid.to_string(), log_file(&"n1"), true); w_cid(cid.to_string(), log_file(&"n1"), true);
} else if prompt_all.contains("アイ") == true
|| prompt_all.contains("うらな") == true
|| prompt_all.contains("") == true
{
if prompt_all.contains("うらな") == true || prompt_all.contains("") == true {
let _output = Command::new(data_scpt(&"ai"))
.arg(&"atproto").arg(&"fortune")
.arg(&handle)
.arg(&did)
.arg(&cid)
.arg(&uri)
.arg(&cid_root)
.arg(&uri_root)
.arg(&host)
.arg(&prompt)
.arg(&prompt_sub)
.output()
.expect("zsh");
}
w_cid(cid.to_string(), log_file(&"n1"), true);
} else if com == "card" || com == "/card" { } else if com == "card" || com == "/card" {
let output = Command::new(data_scpt(&"ai")) let output = Command::new(data_scpt(&"ai"))
.arg(&"atproto").arg(&"card") .arg(&"atproto").arg(&"card")
@ -1055,36 +889,7 @@ pub fn c_bot_feed(c: &Context) {
.await; .await;
println!("{}", str_rep); println!("{}", str_rep);
w_cid(cid.to_string(), log_file(&"n1"), true); w_cid(cid.to_string(), log_file(&"n1"), true);
} else if com == "mitractl" && handle == &admin {
} else if com == "quiz" || com == "/quiz" {
println!("admin:{}", admin);
let output = Command::new(data_scpt(&"ai"))
.arg(&"atproto").arg(&"quiz")
.arg(&handle)
.arg(&did)
.arg(&cid)
.arg(&uri)
.arg(&cid_root)
.arg(&uri_root)
.arg(&host)
.arg(&prompt)
.arg(&prompt_sub)
.output()
.expect("zsh");
let d = String::from_utf8_lossy(&output.stdout);
let d = d.to_string();
let text_limit = c_char(d);
let str_rep = reply::post_request(
text_limit.to_string(),
cid.to_string(),
uri.to_string(),
cid_root.to_string(),
uri_root.to_string(),
)
.await;
println!("{}", str_rep);
w_cid(cid.to_string(), log_file(&"n1"), true);
} else if { com == "mitractl" || com == "/mitractl" } && handle == &admin {
println!("admin:{}", admin); println!("admin:{}", admin);
let output = Command::new(data_scpt(&"ai")) let output = Command::new(data_scpt(&"ai"))
.arg(&"atproto").arg(&"mitra") .arg(&"atproto").arg(&"mitra")
@ -1119,19 +924,6 @@ pub fn c_bot_feed(c: &Context) {
println!("{}", str_rep); println!("{}", str_rep);
w_cid(cid.to_string(), log_file(&"n1"), true); w_cid(cid.to_string(), log_file(&"n1"), true);
} }
} else if com == "@ai" || com == "/ai" {
let str_openai = openai::post_request(prompt_chat.to_string()).await;
let text_limit = c_char(str_openai);
let str_rep = reply::post_request(
text_limit.to_string(),
cid.to_string(),
uri.to_string(),
cid_root.to_string(),
uri_root.to_string(),
)
.await;
println!("{}", str_rep);
w_cid(cid.to_string(), log_file(&"n1"), true);
} }
println!("---"); println!("---");
} }

View File

@ -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,
@ -143,7 +141,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(),
@ -175,7 +172,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,

View File

@ -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;
}

View File

@ -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(&notify).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;
}

View File

@ -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;

View File

@ -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;
}

View File

@ -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;
}

View File

@ -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;
}

View File

@ -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;
}

View File

@ -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;
}

View File

@ -11,12 +11,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 +29,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;
@ -46,15 +39,10 @@ pub mod session;
pub mod timeline_author; pub mod timeline_author;
pub mod token; pub mod token;
pub mod feed_get; 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")
@ -77,21 +65,8 @@ fn main() {
Flag::new("feed", FlagType::String) Flag::new("feed", FlagType::String)
.alias("f"), .alias("f"),
) )
)
.command(
Command::new("feed_watch")
.action(feed_watch)
.flag( .flag(
Flag::new("url", FlagType::String) Flag::new("manga_uri", FlagType::String)
.alias("u"),
)
.flag(
Flag::new("tag", FlagType::String)
.alias("t"),
)
.flag(
Flag::new("debug", FlagType::Bool)
.alias("d"),
) )
) )
.command( .command(
@ -150,170 +125,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 +205,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")
@ -483,13 +290,6 @@ fn bot(c: &Context) {
} }
} }
fn feed_watch(c: &Context) {
refresh(c);
loop {
c_feed_watch(c);
}
}
fn follow_all(_c: &Context) { fn follow_all(_c: &Context) {
c_follow_all(); c_follow_all();
} }
@ -522,12 +322,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);
} }
@ -612,19 +415,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 +428,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 +482,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 +489,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(),

View File

@ -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": [
{ {

View File

@ -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()},

View File

@ -16,7 +16,6 @@ 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

View File

@ -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 --manga_uri $MANGA_URI
ai bot -a $ADMIN

View File

@ -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"
}