From 81ed379cf36b46d97e920eb37e33972f6b4dcf3f Mon Sep 17 00:00:00 2001 From: zyj <18107291228@163.com> Date: Wed, 24 Sep 2025 18:22:25 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E8=B4=A6=E5=8F=B7=E6=B3=A8?= =?UTF-8?q?=E5=86=8C=E6=96=B9=E6=B3=95=EF=BC=8C=E4=BB=A5=E5=8F=8A=E9=82=AE?= =?UTF-8?q?=E7=AE=B1=E5=8D=8F=E8=AE=AE=E5=AF=B9=E6=8E=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- api/twitter.go | 36 ++++ config/index.go | 26 ++- go.mod | 11 +- go.sum | 80 ++++++++ libs/browser.go | 11 ++ libs/chrome.go | 25 +++ libs/error_code.go | 1 + models/browser_instance.go | 17 ++ models/email.go | 17 ++ models/ip.go | 2 +- models/proxy.go | 14 ++ models/twitter_account.go | 24 +++ router/twitter.go | 16 ++ services/bit_browser_service.go | 275 +++++++++++++++++++++++++++ services/browser_instance_service.go | 28 +++ services/email_service.go | 27 +++ services/proxy_service.go | 27 +++ services/twitter_account_service.go | 24 +++ utils/bit_browser_request.go | 244 ++++++++++++++++++++++++ utils/email_imap.go | 125 ++++++++++++ utils/firstmail.go | 68 +++++++ 21 files changed, 1090 insertions(+), 8 deletions(-) create mode 100644 api/twitter.go create mode 100644 models/browser_instance.go create mode 100644 models/email.go create mode 100644 models/proxy.go create mode 100644 models/twitter_account.go create mode 100644 router/twitter.go create mode 100644 services/bit_browser_service.go create mode 100644 services/browser_instance_service.go create mode 100644 services/email_service.go create mode 100644 services/proxy_service.go create mode 100644 services/twitter_account_service.go create mode 100644 utils/bit_browser_request.go create mode 100644 utils/email_imap.go create mode 100644 utils/firstmail.go diff --git a/api/twitter.go b/api/twitter.go new file mode 100644 index 0000000..24c69d5 --- /dev/null +++ b/api/twitter.go @@ -0,0 +1,36 @@ +package api + +import ( + "fmt" + "go-account-register/libs" + "net/http" + + "github.com/gin-gonic/gin" +) + +type Twitter struct{} + +type RegisterParams struct { +} + +func (*Twitter) Register(ctx *gin.Context) { + var res *libs.ErrorInfo + var paramsJson RegisterParams + if err := ctx.ShouldBindJSON(¶msJson); err != nil { + res = libs.ErrorCode["ParamsError"] + fmt.Println(err) + ctx.JSON(http.StatusBadRequest, gin.H{ + "code": res.Code, + "msg": res.Msg, + "data": res.Data, + }) + return + } + // var TwitterService services.TwitterAccountService + // res = TwitterService.Register() + ctx.JSON(http.StatusOK, gin.H{ + "code": res.Code, + "msg": res.Msg, + "data": res.Data, + }) +} diff --git a/config/index.go b/config/index.go index 6c57c6f..38c7d99 100644 --- a/config/index.go +++ b/config/index.go @@ -34,10 +34,28 @@ type Clash struct { } type AppConfig struct { - Port int `yaml:"port"` - Database DatabaseConfig `yaml:"database"` - Limit Limit `yaml:"limit"` - Clash Clash `yaml:"clash"` + Port int `yaml:"port"` + Database DatabaseConfig `yaml:"database"` + Limit Limit `yaml:"limit"` + Clash Clash `yaml:"clash"` + BitBrowser BitBrowserConfig `yaml:"bitBrowser"` + AdsPower AdsPowerConfig `yaml:"adsPower"` + Firstmail FirstmailConfig `yaml:"firstmail"` +} + +type BitBrowserConfig struct { + ApiUrl string `yaml:"apiUrl"` + ApiToken string `yaml:"apiToken"` +} + +type AdsPowerConfig struct { + ApiUrl string `yaml:"apiUrl"` + ApiToken string `yaml:"apiToken"` +} + +type FirstmailConfig struct { + ApiUrl string `yaml:"apiUrl"` + ApiToken string `yaml:"apiToken"` } func LoadConfig() (*AppConfig, error) { diff --git a/go.mod b/go.mod index fc8e91f..bce97c2 100644 --- a/go.mod +++ b/go.mod @@ -19,12 +19,17 @@ require ( require ( filippo.io/edwards25519 v1.1.0 // indirect + github.com/PuerkitoBio/goquery v1.10.3 // indirect + github.com/andybalholm/cascadia v1.3.3 // indirect github.com/bytedance/sonic v1.11.6 // indirect github.com/bytedance/sonic/loader v0.1.1 // indirect github.com/cespare/xxhash/v2 v2.3.0 // indirect github.com/cloudwego/base64x v0.1.4 // indirect github.com/cloudwego/iasm v0.2.0 // indirect github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f // indirect + github.com/emersion/go-imap v1.2.1 // indirect + github.com/emersion/go-message v0.18.2 // indirect + github.com/emersion/go-sasl v0.0.0-20200509203442-7bfe0ed36a21 // indirect github.com/gabriel-vasile/mimetype v1.4.3 // indirect github.com/gin-contrib/sse v0.1.0 // indirect github.com/go-playground/locales v0.14.1 // indirect @@ -49,9 +54,9 @@ require ( github.com/ysmood/gson v0.7.3 // indirect github.com/ysmood/leakless v0.9.0 // indirect golang.org/x/arch v0.8.0 // indirect - golang.org/x/crypto v0.31.0 // indirect - golang.org/x/net v0.33.0 // indirect - golang.org/x/sys v0.28.0 // indirect + golang.org/x/crypto v0.37.0 // indirect + golang.org/x/net v0.39.0 // indirect + golang.org/x/sys v0.32.0 // indirect golang.org/x/text v0.29.0 // indirect google.golang.org/protobuf v1.34.1 // indirect ) diff --git a/go.sum b/go.sum index 37b7474..e0396b2 100644 --- a/go.sum +++ b/go.sum @@ -1,5 +1,9 @@ filippo.io/edwards25519 v1.1.0 h1:FNf4tywRC1HmFuKW5xopWpigGjJKiJSV0Cqo0cJWDaA= filippo.io/edwards25519 v1.1.0/go.mod h1:BxyFTGdWcka3PhytdK4V28tE5sGfRvvvRV7EaN4VDT4= +github.com/PuerkitoBio/goquery v1.10.3 h1:pFYcNSqHxBD06Fpj/KsbStFRsgRATgnf3LeXiUkhzPo= +github.com/PuerkitoBio/goquery v1.10.3/go.mod h1:tMUX0zDMHXYlAQk6p35XxQMqMweEKB7iK7iLNd4RH4Y= +github.com/andybalholm/cascadia v1.3.3 h1:AG2YHrzJIm4BZ19iwJ/DAua6Btl3IwJX+VI4kktS1LM= +github.com/andybalholm/cascadia v1.3.3/go.mod h1:xNd9bqTn98Ln4DwST8/nG+H0yuB8Hmgu1YHNnWw0GeA= github.com/bsm/ginkgo/v2 v2.12.0 h1:Ny8MWAHyOepLGlLKYmXG4IEkioBysk6GpaRTLC8zwWs= github.com/bsm/ginkgo/v2 v2.12.0/go.mod h1:SwYbGRRDovPVboqFv0tPTcG1sN61LM1Z4ARdbAV9g4c= github.com/bsm/gomega v1.27.10 h1:yeMWxP2pV2fG3FgAODIY8EiRE3dy0aeFYt4l7wh6yKA= @@ -19,6 +23,14 @@ github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f h1:lO4WD4F/rVNCu3HqELle0jiPLLBs70cWOduZpkS1E78= github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f/go.mod h1:cuUVRXasLTGF7a8hSLbxyZXjz+1KgoB3wDUb6vlszIc= +github.com/emersion/go-imap v1.2.1 h1:+s9ZjMEjOB8NzZMVTM3cCenz2JrQIGGo5j1df19WjTA= +github.com/emersion/go-imap v1.2.1/go.mod h1:Qlx1FSx2FTxjnjWpIlVNEuX+ylerZQNFE5NsmKFSejY= +github.com/emersion/go-message v0.15.0/go.mod h1:wQUEfE+38+7EW8p8aZ96ptg6bAb1iwdgej19uXASlE4= +github.com/emersion/go-message v0.18.2 h1:rl55SQdjd9oJcIoQNhubD2Acs1E6IzlZISRTK7x/Lpg= +github.com/emersion/go-message v0.18.2/go.mod h1:XpJyL70LwRvq2a8rVbHXikPgKj8+aI0kGdHlg16ibYA= +github.com/emersion/go-sasl v0.0.0-20200509203442-7bfe0ed36a21 h1:OJyUGMJTzHTd1XQp98QTaHernxMYzRaOasRir9hUlFQ= +github.com/emersion/go-sasl v0.0.0-20200509203442-7bfe0ed36a21/go.mod h1:iL2twTeMvZnrg54ZoPDNfJaJaqy0xIQFuBdrLsmspwQ= +github.com/emersion/go-textwrapper v0.0.0-20200911093747-65d896831594/go.mod h1:aqO8z8wPrjkscevZJFVE1wXJrLpC5LtJG7fqLOsPb2U= github.com/fatih/structs v1.1.0 h1:Q7juDM0QtcnhCpeyLGQKyg4TOIghuNXrkL32pHAUMxo= github.com/fatih/structs v1.1.0/go.mod h1:9NiDSp5zOcgEDl+j00MP/WkGVPOlPRLejGD8Ga6PJ7M= github.com/gabriel-vasile/mimetype v1.4.3 h1:in2uUcidCuFcDKtdcBxlR0rJ1+fsokWf+uqxgUFjbI0= @@ -50,6 +62,7 @@ github.com/golang/freetype v0.0.0-20170609003504-e2365dfdc4a0 h1:DACJavvAHhabrF0 github.com/golang/freetype v0.0.0-20170609003504-e2365dfdc4a0/go.mod h1:E/TSTwGwJL78qG/PmXZO1EjYhfJinVAhrmmHX6Z8B9k= github.com/google/go-cmp v0.5.5 h1:Khx7svrCpmxxtHBq5j2mp/xVjsi8hQMfNLvJFAlrGgU= github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= +github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY= github.com/google/gofuzz v1.0.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg= github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0= github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo= @@ -111,23 +124,90 @@ github.com/ysmood/gson v0.7.3/go.mod h1:3Kzs5zDl21g5F/BlLTNcuAGAYLKt2lV5G8D1zF3R github.com/ysmood/leakless v0.8.0/go.mod h1:R8iAXPRaG97QJwqxs74RdwzcRHT1SWCGTNqY8q0JvMQ= github.com/ysmood/leakless v0.9.0 h1:qxCG5VirSBvmi3uynXFkcnLMzkphdh3xx5FtrORwDCU= github.com/ysmood/leakless v0.9.0/go.mod h1:R8iAXPRaG97QJwqxs74RdwzcRHT1SWCGTNqY8q0JvMQ= +github.com/yuin/goldmark v1.4.13/go.mod h1:6yULJ656Px+3vBD8DxQVa3kxgyrAnzto9xy5taEt/CY= golang.org/x/arch v0.0.0-20210923205945-b76863e36670/go.mod h1:5om86z9Hs0C8fWVUuoMHwpExlXzs5Tkyp9hOrfG7pp8= golang.org/x/arch v0.8.0 h1:3wRIsP3pM4yUptoR96otTUOXI367OS0+c9eeRi9doIc= golang.org/x/arch v0.8.0/go.mod h1:FEVrYAQjsQXMVJ1nsMoVVXPZg6p2JE2mx8psSWTDQys= +golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w= +golang.org/x/crypto v0.0.0-20210921155107-089bfa567519/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc= +golang.org/x/crypto v0.13.0/go.mod h1:y6Z2r+Rw4iayiXXAIxJIDAJ1zMW4yaTpebo8fPOliYc= +golang.org/x/crypto v0.19.0/go.mod h1:Iy9bg/ha4yyC70EfRS8jz+B6ybOBKMaSxLj6P6oBDfU= +golang.org/x/crypto v0.23.0/go.mod h1:CKFgDieR+mRhux2Lsu27y0fO304Db0wZe70UKqHu0v8= golang.org/x/crypto v0.31.0 h1:ihbySMvVjLAeSH1IbfcRTkD/iNscyz8rGzjF/E5hV6U= golang.org/x/crypto v0.31.0/go.mod h1:kDsLvtWBEx7MV9tJOj9bnXsPbxwJQ6csT/x4KIN4Ssk= +golang.org/x/crypto v0.37.0 h1:kJNSjF/Xp7kU0iB2Z+9viTPMW4EqqsrywMXLJOOsXSE= +golang.org/x/crypto v0.37.0/go.mod h1:vg+k43peMZ0pUMhYmVAWysMK35e6ioLh3wB8ZCAfbVc= golang.org/x/image v0.31.0 h1:mLChjE2MV6g1S7oqbXC0/UcKijjm5fnJLUYKIYrLESA= golang.org/x/image v0.31.0/go.mod h1:R9ec5Lcp96v9FTF+ajwaH3uGxPH4fKfHHAVbUILxghA= +golang.org/x/mod v0.6.0-dev.0.20220419223038-86c51ed26bb4/go.mod h1:jJ57K6gSWd91VN4djpZkiMVwK6gcyfeH4XE8wZrZaV4= +golang.org/x/mod v0.8.0/go.mod h1:iBbtSCu2XBx23ZKBPSOrRkjjQPZFPuis4dIYUhu/chs= +golang.org/x/mod v0.12.0/go.mod h1:iBbtSCu2XBx23ZKBPSOrRkjjQPZFPuis4dIYUhu/chs= +golang.org/x/mod v0.15.0/go.mod h1:hTbmBsO62+eylJbnUtE2MGJUyE7QWk4xUqPFrRgJ+7c= +golang.org/x/mod v0.17.0/go.mod h1:hTbmBsO62+eylJbnUtE2MGJUyE7QWk4xUqPFrRgJ+7c= +golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s= +golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg= +golang.org/x/net v0.0.0-20220722155237-a158d28d115b/go.mod h1:XRhObCWvk6IyKnWLug+ECip1KBveYUHfp+8e9klMJ9c= +golang.org/x/net v0.6.0/go.mod h1:2Tu9+aMcznHK/AK1HMvgo6xiTLG5rD5rZLDS+rp2Bjs= +golang.org/x/net v0.10.0/go.mod h1:0qNGK6F8kojg2nk9dLZ2mShWaEBan6FAoqfSigmmuDg= +golang.org/x/net v0.15.0/go.mod h1:idbUs1IY1+zTqbi8yxTbhexhEEk5ur9LInksu6HrEpk= +golang.org/x/net v0.21.0/go.mod h1:bIjVDfnllIU7BJ2DNgfnXvpSvtn8VRwhlsaeUTyUS44= +golang.org/x/net v0.25.0/go.mod h1:JkAGAh7GEvH74S6FOH42FLoXpXbE/aqXSrIQjXgsiwM= golang.org/x/net v0.33.0 h1:74SYHlV8BIgHIFC/LrYkOGIwL19eTYXQ5wc6TBuO36I= golang.org/x/net v0.33.0/go.mod h1:HXLR5J+9DxmrqMwG9qjGCxZ+zKXxBru04zlTvWlWuN4= +golang.org/x/net v0.39.0 h1:ZCu7HMWDxpXpaiKdhzIfaltL9Lp31x/3fCP11bc6/fY= +golang.org/x/net v0.39.0/go.mod h1:X7NRbYVEA+ewNkCNyJ513WmMdQ3BineSwVtN2zD/d+E= +golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= +golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= +golang.org/x/sync v0.1.0/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= +golang.org/x/sync v0.3.0/go.mod h1:FU7BRWz2tNW+3quACPkgCx/L+uEAv1htQ0V83Z9Rj+Y= +golang.org/x/sync v0.6.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk= +golang.org/x/sync v0.7.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk= +golang.org/x/sync v0.10.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk= +golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= +golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= +golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.0.0-20220520151302-bc2c85ada10a/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.8.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.12.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.17.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA= +golang.org/x/sys v0.20.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA= golang.org/x/sys v0.28.0 h1:Fksou7UEQUWlKvIdsqzJmUmCX3cZuD2+P3XyyzwMhlA= golang.org/x/sys v0.28.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA= +golang.org/x/sys v0.32.0 h1:s77OFDvIQeibCmezSnk/q6iAfkdiQaJi4VzroCFrN20= +golang.org/x/sys v0.32.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k= +golang.org/x/telemetry v0.0.0-20240228155512-f48c80bd79b2/go.mod h1:TeRTkGYfJXctD9OcfyVLyj2J3IxLnKwHJR8f4D8a3YE= +golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo= +golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8= +golang.org/x/term v0.5.0/go.mod h1:jMB1sMXY+tzblOD4FWmEbocvup2/aLOaQEp7JmGp78k= +golang.org/x/term v0.8.0/go.mod h1:xPskH00ivmX89bAKVGSKKtLOWNx2+17Eiy94tnKShWo= +golang.org/x/term v0.12.0/go.mod h1:owVbMEjm3cBLCHdkQu9b1opXd4ETQWc3BhuQGKgXgvU= +golang.org/x/term v0.17.0/go.mod h1:lLRBjIVuehSbZlaOtGMbcMncT+aqLLLmKrsjNrUguwk= +golang.org/x/term v0.20.0/go.mod h1:8UkIAJTvZgivsXaD6/pH6U9ecQzZ45awqEOzuCvwpFY= +golang.org/x/term v0.27.0/go.mod h1:iMsnZpn0cago0GOrHO2+Y7u7JPn5AylBrcoWkElMTSM= +golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= +golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= +golang.org/x/text v0.3.6/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= +golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ= +golang.org/x/text v0.7.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8= +golang.org/x/text v0.9.0/go.mod h1:e1OnstbJyHTd6l/uOt8jFFHp6TRDWZR/bV3emEE/zU8= +golang.org/x/text v0.13.0/go.mod h1:TvPlkZtksWOMsz7fbANvkp4WM8x/WCo/om8BMLbz+aE= +golang.org/x/text v0.14.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU= +golang.org/x/text v0.15.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU= +golang.org/x/text v0.21.0/go.mod h1:4IBbMaMmOPCJ8SecivzSH54+73PCFmPWxNTLm+vZkEQ= golang.org/x/text v0.29.0 h1:1neNs90w9YzJ9BocxfsQNHKuAT4pkghyXc4nhZ6sJvk= golang.org/x/text v0.29.0/go.mod h1:7MhJOA9CD2qZyOKYazxdYMF85OwPdEr9jTtBpO7ydH4= golang.org/x/time v0.6.0 h1:eTDhh4ZXt5Qf0augr54TN6suAUudPcawVZeIAPU7D4U= golang.org/x/time v0.6.0/go.mod h1:3BpzKBy/shNhVucY/MWOyx10tF3SFh9QdLuxbVysPQM= +golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ= +golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo= +golang.org/x/tools v0.1.12/go.mod h1:hNGJHUnrk76NpqgfD5Aqm5Crs+Hm0VOH/i9J2+nxYbc= +golang.org/x/tools v0.6.0/go.mod h1:Xwgl3UAJ/d3gWutnCtw505GrjyAbvKui8lOU390QaIU= +golang.org/x/tools v0.13.0/go.mod h1:HvlwmtVNQAhOuCjW7xxvovg8wbNq7LwfXh/k7wXUl58= +golang.org/x/tools v0.21.1-0.20240508182429-e35e4ccd0d2d/go.mod h1:aiJjzUbINMkxbQROHiO6hDPo2LHcIPhhQsa9DLh0yGk= +golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543 h1:E7g+9GITq07hpfrRu66IVDexMakfv52eLZ2CXBWiKr4= golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= google.golang.org/protobuf v1.34.1 h1:9ddQBjfCyZPOHPUiPxpYESBLc+T8P3E+Vo4IbKZgFWg= diff --git a/libs/browser.go b/libs/browser.go index a103938..8075628 100644 --- a/libs/browser.go +++ b/libs/browser.go @@ -93,3 +93,14 @@ func (*Browser) CancelBrowser(id int) { browserInfo.Browser.MustClose() delete(BrowserPool, id) } + +func (*Browser) GetBitBrowser(ws string) *BrowserInfo { + var ChromeExample Chrome + browser, url, page := ChromeExample.ConnectBitBrowser(ws) + browserInfo := &BrowserInfo{ + Browser: browser, + Url: url, + Page: page, + } + return browserInfo +} diff --git a/libs/chrome.go b/libs/chrome.go index bf08a20..11e2e0b 100644 --- a/libs/chrome.go +++ b/libs/chrome.go @@ -18,6 +18,31 @@ import ( type Chrome struct{} +func (c *Chrome) ConnectBitBrowser(url string) (*rod.Browser, string, *rod.Page) { + log.Println("浏览器的URL", url) + browser := rod.New(). + ControlURL(url). + MustConnect().NoDefaultDevice() + browser.MustIgnoreCertErrors(true) + + // var page *rod.Page + // pages := browser.MustPages() + // if len(pages) >= 2 { + // page = pages[1] + // } else { + + // } + page := browser.MustPage() + go browser.EachEvent(func(e *proto.TargetTargetCreated) { + if e.TargetInfo.Type != proto.TargetTargetInfoTypePage { + return + } + browser.MustPageFromTargetID(e.TargetInfo.TargetID).MustEvalOnNewDocument(stealth.JS) + })() + + return browser, url, page +} + func (c *Chrome) Create(accountId int, params *Fingerprint) (*rod.Browser, string, *rod.Page) { var accountIdStr = strconv.Itoa(accountId) userDataDir := "user-data/" + accountIdStr diff --git a/libs/error_code.go b/libs/error_code.go index 57bf7c5..6c1a1ec 100644 --- a/libs/error_code.go +++ b/libs/error_code.go @@ -30,4 +30,5 @@ var ErrorCode = map[string]*ErrorInfo{ "MaintainAccountFailed": {Code: 0, Data: "", Msg: "养号运行失败"}, "RegisterFailed": {Code: 0, Data: "", Msg: "注册失败"}, "RegisterSuccessful": {Code: 0, Data: "", Msg: "注册成功"}, + "BrowserCreationFailed": {Code: 0, Data: "", Msg: "浏览器创建失败"}, } diff --git a/models/browser_instance.go b/models/browser_instance.go new file mode 100644 index 0000000..f224e0a --- /dev/null +++ b/models/browser_instance.go @@ -0,0 +1,17 @@ +package models + +type BrowserInstance struct { + ID int64 `gorm:"id;primary_key;auto_increment"` + Proxy string `gorm:"proxy"` + BrowserId string `gorm:"browser_id"` + UseStatus int `gorm:"use_status"` + Fingerprint map[string]interface{} `gorm:"fingerprint;type:json;serializer:json"` + BrowserUrl string `grom:"browser_url"` + UpdateTime int64 `gorm:"update_time"` + CreateTime int64 `gorm:"create_time"` +} + +// 实现 TableName 方法指定表名 +func (BrowserInstance) TableName() string { + return "browser_instance" +} diff --git a/models/email.go b/models/email.go new file mode 100644 index 0000000..94ec199 --- /dev/null +++ b/models/email.go @@ -0,0 +1,17 @@ +package models + +type Email struct { + ID int64 `gorm:"id;primary_key;auto_increment"` + Name string `gorm:"name"` + Email string `gorm:"email"` + Password string `gorm:"password"` + UseStatus string `gorm:"use_status"` + Platform string `gorm:"platform"` + UpdateTime int64 `gorm:"update_time"` + CreateTime int64 `gorm:"create_time"` +} + +// 实现 TableName 方法指定表名 +func (Email) TableName() string { + return "ar_email" +} diff --git a/models/ip.go b/models/ip.go index 0dc24c3..ab6ac47 100644 --- a/models/ip.go +++ b/models/ip.go @@ -30,5 +30,5 @@ type Ip struct { // 实现 TableName 方法指定表名 func (Ip) TableName() string { - return "j_ip" + return "ar_ip" } diff --git a/models/proxy.go b/models/proxy.go new file mode 100644 index 0000000..f7b0212 --- /dev/null +++ b/models/proxy.go @@ -0,0 +1,14 @@ +package models + +type Proxy struct { + ID int64 `gorm:"id;primary_key;auto_increment"` + Proxy string `gorm:"proxy"` + Type string `gorm:"type"` + UseStatus string `gorm:"use_status"` + UpdateTime int64 `gorm:"update_time"` + CreateTime int64 `gorm:"create_time"` +} + +func (Proxy) TableName() string { + return "ar_proxy" +} diff --git a/models/twitter_account.go b/models/twitter_account.go new file mode 100644 index 0000000..4a226e0 --- /dev/null +++ b/models/twitter_account.go @@ -0,0 +1,24 @@ +package models + +import "github.com/go-rod/rod/lib/proto" + +type TwitterAccount struct { + ID int64 `gorm:"id;primary_key;auto_increment"` + Name string `gorm:"name"` + Email string `gorm:"email"` + Password string `gorm:"password"` + Birthday string `gorm:"birthday"` + Token string `gorm:"token"` + Fa2 string `gorm:"fa2"` + Cookies []*proto.NetworkCookieParam `gorm:"img;type:json;serializer:json"` + Status string `gorm:"status"` + LoginStatus string `gorm:"login_status"` + Proxy string `gorm:"proxy"` + UpdateTime int64 `gorm:"update_time"` + CreateTime int64 `gorm:"create_time"` +} + +// 实现 TableName 方法指定表名 +func (TwitterAccount) TableName() string { + return "ar_twitter_account" +} diff --git a/router/twitter.go b/router/twitter.go new file mode 100644 index 0000000..e9724cc --- /dev/null +++ b/router/twitter.go @@ -0,0 +1,16 @@ +package router + +import ( + "go-account-register/api" + + "github.com/gin-gonic/gin" +) + +type Twitter struct{} + +var twitterApi api.Twitter + +func (*Twitter) TwitterRouterInit(app *gin.Engine) { + twitter := app.Group("/twitter") + twitter.POST("/register", twitterApi.Register) +} diff --git a/services/bit_browser_service.go b/services/bit_browser_service.go new file mode 100644 index 0000000..46f6aaf --- /dev/null +++ b/services/bit_browser_service.go @@ -0,0 +1,275 @@ +package services + +import ( + "encoding/json" + "fmt" + "go-account-register/libs" + "go-account-register/models" + "go-account-register/utils" + "log" + "strconv" + "time" + + "github.com/go-rod/rod" + "github.com/go-rod/rod/lib/proto" +) + +type BitBrowserService struct { +} + +var Browser libs.Browser +var Chrome libs.Chrome + +func (*BitBrowserService) CreateBrowser(proxy *models.Proxy) string { + fingerprint := map[string]interface{}{ + "name": fmt.Sprintf(`推特注册%s`, utils.RandString(10)), + "proxyMethod": 2, + "proxyType": "noproxy", + "host": "", + "port": 0, + "proxyUserName": "", + "proxyPassword": "", + "randomFingerprint": true, + "syncTabs": false, + "syncCookies": false, + "browserFingerPrint": map[string]interface{}{ + "coreVersion": "130", + "ostype": "PC", + "os": "Win32", + "osVersion": "11,10", + "openWidth": 1920, + "openHeight": 1480, + "resolutionType": "0", + }, + } + if proxy != nil { + var proxyHandle utils.ProxyHandle + protocol, username, password, ip, port, err2 := proxyHandle.ParseProxy(proxy.Type + "://" + proxy.Proxy) + if err2 == nil { + fingerprint["proxyType"] = protocol + fingerprint["host"] = ip + fingerprint["port"] = port + fingerprint["proxyUserName"] = username + fingerprint["proxyPassword"] = password + } + + } + bitBrowserRequest := utils.NewBitBrowserRequest() + jsonStr, _ := bitBrowserRequest.CreateBrowser(fingerprint) + var rawData map[string]interface{} + if err := json.Unmarshal([]byte(jsonStr.Body()), &rawData); err != nil { + panic(err) + } + success := rawData["success"].(bool) + if success { + // 如果成功则将数据存入数据库 + data := rawData["data"].(map[string]interface{}) + id := data["id"].(string) + browserInstanceService := InitBrowserInstanceService() + var params = &models.BrowserInstance{ + BrowserId: id, + Fingerprint: data, + UpdateTime: time.Now().Unix(), + CreateTime: time.Now().Unix(), + } + if proxy != nil { + params.Proxy = proxy.Type + "://" + proxy.Proxy + } + browserInstanceService.Create(params) + return id + } + return "" +} + +func (*BitBrowserService) GetPid(id string) int { + // 获取当前 + bitBrowserRequest := utils.NewBitBrowserRequest() + jsonStr, _ := bitBrowserRequest.GetPids([]string{id}) + var result struct { + Data map[string]int `json:"data"` // 动态键名 → 值 + Success bool `json:"success"` + } + if err := json.Unmarshal([]byte(jsonStr.Body()), &result); err != nil { + panic(err) + } + success := result.Success + if success { + data := result.Data + if value, exists := data[id]; exists { + return value + } else { + return 0 + } + } + return 0 +} + +// 打开浏览器 +func (*BitBrowserService) OpenBrowser(browserId string) string { + // 获取当前 + bitBrowserRequest := utils.NewBitBrowserRequest() + data := map[string]interface{}{ + "id": browserId, + "queue": true, + } + jsonStr, _ := bitBrowserRequest.OpenBrowser(data) + var rawData map[string]interface{} + if err := json.Unmarshal([]byte(jsonStr.Body()), &rawData); err != nil { + panic(err) + } + success := rawData["success"].(bool) + if success { + data := rawData["data"].(map[string]interface{}) + ws := data["ws"].(string) + browserInstanceService := InitBrowserInstanceService() + browserInstanceService.Update(browserId, &models.BrowserInstance{ + BrowserUrl: ws, + }) + return ws + } + return "" +} + +// 删除浏览器 +func (*BitBrowserService) DeleteBrowser(browserId string) bool { + bitBrowserRequest := utils.NewBitBrowserRequest() + // 先关闭浏览器 + _, err := bitBrowserRequest.CloseBrowser(browserId) + if err != nil { + log.Println("关闭浏览器失败") + } + // 删除浏览器 + _, err2 := bitBrowserRequest.DeleteBrowser(browserId) + log.Println("删除浏览器，", err2 == nil) + return err2 == nil +} + +func (bit *BitBrowserService) Register() *libs.ErrorInfo { + // 随机获取代理 + proxyService := InitProxyService() + proxy := proxyService.GetInfo() + var browserId string + // 创建新的浏览器 + if proxy != nil { + browserId = bit.CreateBrowser(proxy) + } else { + browserId = bit.CreateBrowser(nil) + } + // 打开浏览器 + if browserId == "" { + return libs.ErrorCode["BrowserCreationFailed"] + } + ws := bit.OpenBrowser(browserId) + if ws == "" { + return libs.ErrorCode["BrowserCreationFailed"] + } + // 获取一个邮箱 + emailService := InitEmailService() + + emailInfo := emailService.GetEmailOne() + obj := Browser.GetBitBrowser(ws) + page := obj.Page + page.MustNavigate("https://x.com/i/flow/signup").MustWaitLoad() + // 判断当前是否是邮箱注册 + _, err := page.Element(`input[name="email"]`) + if err != nil { + switchButton := page.Timeout(5 * time.Second).MustElement(`button.css-146c3p1.r-bcqeeo.r-qvutc0.r-1qd0xha.r-1ff274t.r-a023e6.r-rjixqe.r-16dba41`) + switchButton.MustClick() + } + // 获取邮箱输入框 + inputEmail := page.Timeout(5 * time.Second).MustElement(`input[name="email"]`) + inputEmail.MustFocus() + inputEmail.MustInput(emailInfo.Email) + // 获取名称输入框 + inputName := page.Timeout(5 * time.Second).MustElement(`input[name="name"]`) + inputName.MustFocus() + nameStr := emailInfo.Name + if emailInfo.Name == "" { + nameStr = utils.RandString(12) + } + inputName.MustInput(nameStr) + // 随机生成生日 + dateParams := utils.RandDate(18, 100) + dateSelects, _ := page.Timeout(5 * time.Second).Elements(`select.r-30o5oe.r-1niwhzg.r-17gur6a.r-1yadl64.r-18jsvk2.r-1loqt21.r-1inkyih.r-rjixqe.r-crgep1.r-1wzrnnt.r-1ny4l3l.r-t60dpp.r-xd6kpl.r-is05cd.r-ttdzmv`) + // 月份 + dateSelects[0].WaitVisible() + dateSelects[0].MustSelect(strconv.Itoa(dateParams.Month)) + // 日期 + dateSelects[1].WaitVisible() + dateSelects[1].MustSelect(strconv.Itoa(dateParams.Day)) + // 年份 + dateSelects[2].WaitVisible() + dateSelects[2].MustSelect(strconv.Itoa(dateParams.Year)) + + // 点击下一步 + ocfSignupNextLink := page.Timeout(5 * time.Second).MustElement(`button[data-testid="ocfSignupNextLink"]`) + ocfSignupNextLink.MustClick() + // 判断是否需要验证码 + time.Sleep(4 * time.Second) + codeInput, err1 := page.Timeout(5 * time.Second).Element(`input[name="verfication_code"]`) + if err1 != nil { + // res := getApiResponse(page, "") + } + //TODO 对接获取邮箱信息接口 + // 获取邮箱验证码 + codeInput.MustInput("") + // 点击下一步 + codeNextButton := page.Timeout(5 * time.Second).MustElement(`button.css-175oi2r.r-sdzlij.r-1phboty.r-rs99b7.r-lrvibr.r-19yznuf.r-64el8z.r-1fkl15p.r-1loqt21.r-o7ynqc.r-6416eg.r-1ny4l3l`) + codeNextButton.MustClick() + // // 点击验证按钮 + // verifyButton := page.Timeout(5 * time.Second).MustElement(`button[data-theme="home.verifyButton"]`) + // verifyButton.MustClick() + // 输入密码 + passwordInput, err2 := page.Timeout(5 * time.Second).Element(`input[name="password"]`) + if err2 != nil { + // res := getApiResponse(page, "") + } + passwordInput.MustInput(emailInfo.Password) + // 点击下一步 + loginButton := page.Timeout(5 * time.Second).MustElement(`button[data-testid="LoginForm_Login_Button"]`) + loginButton.MustClick() + time.Sleep(5 * time.Second) + page.MustNavigate("https://x.com").MustWaitLoad() + // 获取cookie + cookieArr := getPageCookie(page, "https://x.com") + // 创建用户 + twitterAccountService := InitTwitterAccountService() + twitterAccountService.Create(&models.TwitterAccount{ + Name: nameStr, + Email: emailInfo.Email, + Password: emailInfo.Password, + Birthday: strconv.Itoa(dateParams.Year) + "-" + strconv.Itoa(dateParams.Month) + "-" + strconv.Itoa(dateParams.Day), + Cookies: cookieArr, + Status: "注册成功", + LoginStatus: "登录成功", + Proxy: func() string { + if proxy != nil { + return proxy.Type + "://" + proxy.Proxy + } + return "" + }(), + }) + + // 删除浏览器 + bit.DeleteBrowser(browserId) + return libs.ErrorCode["RegisterSuccessful"] + +} + +// 获取指定页面的cookie列表 +func getPageCookie(page *rod.Page, url string) []*proto.NetworkCookieParam { + cookieArr, _ := page.Cookies([]string{url}) + var cookies []*proto.NetworkCookieParam + for _, cookie := range cookieArr { + cookies = append(cookies, &proto.NetworkCookieParam{ + Name: cookie.Name, + Value: cookie.Value, + Domain: cookie.Domain, + Path: cookie.Path, + Expires: cookie.Expires, // 过期时间 + HTTPOnly: cookie.HTTPOnly, // 禁止 JS 访问 + Secure: cookie.Secure, // 仅 HTTPS 传输 + }) + } + return cookies +} diff --git a/services/browser_instance_service.go b/services/browser_instance_service.go new file mode 100644 index 0000000..2476496 --- /dev/null +++ b/services/browser_instance_service.go @@ -0,0 +1,28 @@ +package services + +import ( + "go-account-register/models" + "go-account-register/utils" + "time" + + "gorm.io/gorm" +) + +type BrowserInstanceService struct { + db *gorm.DB +} + +func InitBrowserInstanceService() *BrowserInstanceService { + db := utils.GetDB() + + return &BrowserInstanceService{db: db} +} + +func (b *BrowserInstanceService) Create(params *models.BrowserInstance) { + b.db.Create(params) +} + +func (b *BrowserInstanceService) Update(browserId string, params *models.BrowserInstance) { + params.UpdateTime = time.Now().Unix() + b.db.Model(&models.BrowserInstance{}).Updates(params) +} diff --git a/services/email_service.go b/services/email_service.go new file mode 100644 index 0000000..77f2adf --- /dev/null +++ b/services/email_service.go @@ -0,0 +1,27 @@ +package services + +import ( + "go-account-register/models" + "go-account-register/utils" + + "gorm.io/gorm" +) + +type EmailService struct { + db *gorm.DB +} + +func InitEmailService() *EmailService { + db := utils.GetDB() + + return &EmailService{db: db} +} + +func (e *EmailService) GetEmailOne() *models.Email { + var email models.Email + err := e.db.Model(email).Where("use_status = ?", 0).First(&email).Error + if err != nil { + return nil + } + return &email +} diff --git a/services/proxy_service.go b/services/proxy_service.go new file mode 100644 index 0000000..1135ca5 --- /dev/null +++ b/services/proxy_service.go @@ -0,0 +1,27 @@ +package services + +import ( + "go-account-register/models" + "go-account-register/utils" + + "gorm.io/gorm" +) + +type ProxyService struct { + db *gorm.DB +} + +func InitProxyService() *ProxyService { + db := utils.GetDB() + + return &ProxyService{db: db} +} + +func (p *ProxyService) GetInfo() *models.Proxy { + var proxy models.Proxy + result := p.db.Model(&models.Proxy{}).Order("RAND()").Limit(1).Find(&proxy) + if result.Error != nil { + return nil + } + return &proxy +} diff --git a/services/twitter_account_service.go b/services/twitter_account_service.go new file mode 100644 index 0000000..fc4bfd4 --- /dev/null +++ b/services/twitter_account_service.go @@ -0,0 +1,24 @@ +package services + +import ( + "go-account-register/models" + "go-account-register/utils" + "time" + + "gorm.io/gorm" +) + +type TwitterAccountService struct { + db *gorm.DB +} + +func InitTwitterAccountService() *TwitterAccountService { + db := utils.GetDB() + return &TwitterAccountService{db: db} +} + +func (t *TwitterAccountService) Create(params *models.TwitterAccount) { + params.CreateTime = time.Now().Unix() + params.UpdateTime = time.Now().Unix() + t.db.Create(params) +} diff --git a/utils/bit_browser_request.go b/utils/bit_browser_request.go new file mode 100644 index 0000000..6047ea5 --- /dev/null +++ b/utils/bit_browser_request.go @@ -0,0 +1,244 @@ +package utils + +import ( + "errors" + "go-account-register/config" + "log" + + "github.com/go-resty/resty/v2" +) + +type BitBrowserRequest struct { + client *resty.Client +} + +func NewBitBrowserRequest() *BitBrowserRequest { + appConfig, _ := config.LoadConfig() + client := resty.New() + client.SetBaseURL(appConfig.BitBrowser.ApiUrl) + + // 响应拦截器 (类似 axios 拦截器) + client.OnAfterResponse(func(c *resty.Client, resp *resty.Response) error { + if resp.StatusCode() != 200 { + log.Println("请求失败，检查网络") + return errors.New("request failed") + } + return nil + }) + + return &BitBrowserRequest{client: client} +} + +// Request 发送通用请求 +func (h *BitBrowserRequest) Request(method, url string, data interface{}) (*resty.Response, error) { + resp, err := h.client.R(). + SetHeader("Content-Type", "application/json"). + SetBody(data). + Execute(method, url) + + if err != nil { + log.Println("请求失败了:", err) + return nil, err + } + return resp, nil +} + +/** + * @description 打开浏览器并返回wspoint + * @returns {Promise} Promise + * @param {Object} data + * @param {String} data.id 窗口id + * @param {Array} data.args 启动附加参数，数组类型，比如 ["--headless"] + * @param {Boolean} data.loadExtensions 是否加载扩展 + * @param {Boolean} data.extractIp 是否尝试提取IP + */ +func (h *BitBrowserRequest) OpenBrowser(data map[string]interface{}) (*resty.Response, error) { + return h.Request("POST", "/browser/open", data) +} + +/** + * @description 关闭浏览器 + * @param {String} id + * @returns {Promise} + */ +func (h *BitBrowserRequest) CloseBrowser(id string) (*resty.Response, error) { + return h.Request("POST", "/browser/close", map[string]interface{}{"id": id}) +} + +/** + * @description 创建浏览器 + * @param {Object} data + * @returns {Promise} + */ +func (h *BitBrowserRequest) CreateBrowser(data map[string]interface{}) (*resty.Response, error) { + return h.Request("POST", "/browser/update", data) +} + +/** + * @description 修改browser信息，只修改传入的配置 + * @param {Object} data 参考创建配置项 + * @returns {Promise} + */ +func (h *BitBrowserRequest) UpdatePartial(data map[string]interface{}) (*resty.Response, error) { + return h.Request("POST", "/browser/update/partial", data) +} + +/** + * @description 批量删除浏览器 + * @param {array} ids + */ +func (h *BitBrowserRequest) DeleteBatchBrowser(ids []string) (*resty.Response, error) { + return h.Request("POST", "/browser/delete/ids", map[string]interface{}{"ids": ids}) +} + +/** + * @description 删除浏览器 + * @param {String} id + * @returns {Promise} + */ +func (h *BitBrowserRequest) DeleteBrowser(id string) (*resty.Response, error) { + return h.Request("POST", "/browser/delete", map[string]interface{}{"id": id}) +} + +/** + * @description 获取浏览器详情 + * @param {String} id + * @returns {Promise} + * */ +func (h *BitBrowserRequest) GetBrowserDetail(id string) (*resty.Response, error) { + return h.Request("POST", "/browser/detail", map[string]interface{}{"id": id}) +} + +/** + * @description 获取浏览器列表 + * @param {Object} data + * @param {Number} data.page // 必传 + * @param {Number} data.pageSize // 必传 + * @param {String} data.groupId // 分组ID，非必传 + * @param {String} data.name // 窗口名称，用于模糊查询，非必传 + * @param {String} data.sortProperties // 排序参数，默认序号，seq，非必传 + * @param {String} data.sortDirection // 排序顺序参数，默认desc，可传asc，非必传 + * @returns {Promise} + * */ +func (h *BitBrowserRequest) GetBrowserList(data map[string]interface{}) (*resty.Response, error) { + return h.Request("POST", "/browser/list", data) +} + +/** + * @description 获取浏览器列表（简洁） + */ +func (h *BitBrowserRequest) GetBrowserConciseList(data map[string]interface{}) (*resty.Response, error) { + return h.Request("POST", "/browser/list/concise", data) +} + +/** + * @description 分组list + * @param {Number} page 从0开始 + * @param {Number} pageSize 例如10 + * @returns {Promise} + * */ +func (h *BitBrowserRequest) GetGroupList(page, pageSize int) (*resty.Response, error) { + return h.Request("POST", "/group/list", map[string]interface{}{"page": page, "pageSize": pageSize}) +} + +/** + * @description 添加分组 + * @param {String} groupName + * @param {Number} sortNum + * @returns {Promise} + * */ +func (h *BitBrowserRequest) AddGroup(groupName string, sortNum int) (*resty.Response, error) { + return h.Request("POST", "/group/add", map[string]interface{}{"groupName": groupName, "sortNum": sortNum}) +} + +/** + * @description 修改分组 + * @param {String} id + * @param {String} groupName + * @param {Number} sortNum + * @returns {Promise} + * */ +func (h *BitBrowserRequest) EditGroup(id, groupName string, sortNum int) (*resty.Response, error) { + return h.Request("POST", "/group/edit", map[string]interface{}{"id": id, "groupName": groupName, "sortNum": sortNum}) +} + +/** + * @description 删除分组 + * @param {String} id + * @returns {Promise} + * */ +func (h *BitBrowserRequest) DeleteGroup(id string) (*resty.Response, error) { + return h.Request("POST", "/group/delete", map[string]interface{}{"id": id}) +} + +/** + * @description 分组详情 + * @param {String} id + * */ +func (h *BitBrowserRequest) GetGroupDetail(id string) (*resty.Response, error) { + return h.Request("POST", "/group/detail", map[string]interface{}{"id": id}) +} + +/** + * @description 获取指定窗口的pids + * @param {Array} ids + * @returns + */ +func (h *BitBrowserRequest) GetPids(ids []string) (*resty.Response, error) { + return h.Request("POST", "/browser/pids", map[string]interface{}{"ids": ids}) +} + +/** + * @description 获取活着窗口的pids + * @param {Array} ids + * @returns + */ +func (h *BitBrowserRequest) GetAlivePids(ids []string) (*resty.Response, error) { + return h.Request("POST", "/browser/pids/alive", map[string]interface{}{"ids": ids}) +} + +/** + * @description 获取所有活着窗口的pids + * @returns + */ +func (h *BitBrowserRequest) GetAliveBrowsersPids() (*resty.Response, error) { + return h.Request("POST", "/browser/pids/all", nil) +} + +/** + * @description 批量修改窗口备注 + * @param {String} remark + * @param {Array} browserIds + * @returns + */ +func (h *BitBrowserRequest) UpdateBrowserRemark(remark string, browserIds []string) (*resty.Response, error) { + return h.Request("POST", "/browser/remark/update", map[string]interface{}{"remark": remark, "browserIds": browserIds}) +} + +/** + * @description 批量修改窗口分组 + * @param {Object} data + * @param {Number} data.groupId + * @param {Array} data.browserIds + */ +func (h *BitBrowserRequest) BatchUpdateBrowserGroup(data map[string]interface{}) (*resty.Response, error) { + return h.Request("POST", "/browser/group/update", data) +} + +/** + * @description 通过序号批量关闭浏览器 + * + */ +func (h *BitBrowserRequest) CloseBrowsersBySeqs(seqs []int) (*resty.Response, error) { + return h.Request("POST", "/browser/close/byseqs", map[string]interface{}{"seqs": seqs}) +} + +/** + * @description 批量修改代理 + * @param {Object} data + * @param {Number} data.proxyMethod //代理类型，2自定义代理，3提取IP + * @param {String} data.proxyType // 自定义代理类型 + */ +func (h *BitBrowserRequest) BatchUpdateProxy(data map[string]interface{}) (*resty.Response, error) { + return h.Request("POST", "/browser/proxy/update", data) +} diff --git a/utils/email_imap.go b/utils/email_imap.go new file mode 100644 index 0000000..27bf878 --- /dev/null +++ b/utils/email_imap.go @@ -0,0 +1,125 @@ +package utils + +import ( + "fmt" + "io" + "log" + "strings" + + "github.com/PuerkitoBio/goquery" + "github.com/emersion/go-imap" + "github.com/emersion/go-imap/client" + "github.com/emersion/go-message/mail" +) + +type EmailImap struct { +} + +// 获取最新一封邮件的正文内容 +func (*EmailImap) GetLatestMailContent(server, username, password string) (string, error) { + // 1. 连接 IMAP 服务器 (SSL/TLS, 端口 993) + c, err := client.DialTLS(server, nil) + if err != nil { + return "", fmt.Errorf("连接失败: %v", err) + } + defer c.Logout() + + // 2. 登录 + if err := c.Login(username, password); err != nil { + return "", fmt.Errorf("登录失败: %v", err) + } + + // 3. 选择收件箱 + mbox, err := c.Select("INBOX", false) + if err != nil { + return "", fmt.Errorf("选择收件箱失败: %v", err) + } + if mbox.Messages == 0 { + return "", nil // 没有邮件 + } + + // 4. 获取最新一封邮件 + seqset := new(imap.SeqSet) + seqset.AddNum(mbox.Messages) + + section := &imap.BodySectionName{} + messages := make(chan *imap.Message, 1) + go func() { + if err := c.Fetch(seqset, []imap.FetchItem{section.FetchItem()}, messages); err != nil { + log.Println("获取邮件失败:", err) + } + }() + + msg := <-messages + if msg == nil { + return "", nil + } + + r := msg.GetBody(section) + if r == nil { + return "", nil + } + + // 5. 解析邮件正文 + mr, err := mail.CreateReader(r) + if err != nil { + return "", fmt.Errorf("解析邮件失败: %v", err) + } + + var content string + for { + p, err := mr.NextPart() + if err == io.EOF { + break + } + if err != nil { + return "", fmt.Errorf("读取邮件失败: %v", err) + } + + switch p.Header.(type) { + case *mail.InlineHeader: + b, _ := io.ReadAll(p.Body) + content = strings.TrimSpace(string(b)) + // 只取第一个正文即可 + return content, nil + } + } + + return content, nil +} + +func (e *EmailImap) GetMailCode(server, username, password string) string { + res, err := e.GetLatestMailContent(server, username, password) + if err != nil { + return "0" + } + + htmlStr := res + fmt.Println(htmlStr) + + doc, err := goquery.NewDocumentFromReader(strings.NewReader(htmlStr)) + if err != nil { + return "0" + } + + code := "" + doc.Find("td.h1.black").Each(func(i int, s *goquery.Selection) { + if code == "" { + code = strings.TrimSpace(s.Text()) + } + }) + + if code == "" { + return "0" + } + return code +} + +func test() { + var emailImap EmailImap + content, err := emailImap.GetLatestMailContent("pop.dragonsmail.com:993", "CamilleMathews1u8K@dragonsmail.com", "vDgADn`zga.") + if err != nil { + log.Fatal(err) + } + fmt.Println("最新邮件内容:\n", content) +} diff --git a/utils/firstmail.go b/utils/firstmail.go new file mode 100644 index 0000000..e2ebac3 --- /dev/null +++ b/utils/firstmail.go @@ -0,0 +1,68 @@ +package utils + +import ( + "encoding/json" + "fmt" + "go-account-register/config" + "strings" + + "github.com/PuerkitoBio/goquery" + "github.com/go-resty/resty/v2" +) + +type Firstmail struct { +} + +type MailResponse struct { + Message string `json:"message"` +} + +func (f *Firstmail) GetFirstmailMail(username, password string) (*MailResponse, error) { + client := resty.New() + appConfig, _ := config.LoadConfig() + url := fmt.Sprintf("%s?username=%s&password=%s", + appConfig.Firstmail.ApiUrl, username, password) + + resp, err := client.R(). + SetHeader("accept", "application/json"). + SetHeader("X-API-KEY", appConfig.Firstmail.ApiToken). + Get(url) + + if err != nil { + return nil, err + } + + var data MailResponse + if err := json.Unmarshal(resp.Body(), &data); err != nil { + return nil, err + } + + return &data, nil +} + +func (f *Firstmail) GetMailCode(username, password string) string { + res, err := f.GetFirstmailMail(username, password) + if err != nil { + return "0" + } + + htmlStr := res.Message + fmt.Println(htmlStr) + + doc, err := goquery.NewDocumentFromReader(strings.NewReader(htmlStr)) + if err != nil { + return "0" + } + + code := "" + doc.Find("td.h1.black").Each(func(i int, s *goquery.Selection) { + if code == "" { + code = strings.TrimSpace(s.Text()) + } + }) + + if code == "" { + return "0" + } + return code +}