515 lines
15 KiB
Go
515 lines
15 KiB
Go
package service
|
||
|
||
import (
|
||
"context"
|
||
"crypto/md5"
|
||
"encoding/hex"
|
||
"encoding/json"
|
||
"fmt"
|
||
"io"
|
||
"io/ioutil"
|
||
"net"
|
||
"os"
|
||
path2 "path"
|
||
"reflect"
|
||
"strconv"
|
||
"strings"
|
||
"time"
|
||
|
||
"github.com/IceWhaleTech/CasaOS/model"
|
||
"github.com/IceWhaleTech/CasaOS/pkg/config"
|
||
"github.com/IceWhaleTech/CasaOS/pkg/quic_helper"
|
||
"github.com/IceWhaleTech/CasaOS/pkg/utils/file"
|
||
"github.com/IceWhaleTech/CasaOS/pkg/utils/ip_helper"
|
||
model2 "github.com/IceWhaleTech/CasaOS/service/model"
|
||
"github.com/IceWhaleTech/CasaOS/types"
|
||
"github.com/lucas-clemente/quic-go"
|
||
uuid "github.com/satori/go.uuid"
|
||
)
|
||
|
||
var UDPConn *net.UDPConn
|
||
var PeopleMap map[string]quic.Stream
|
||
var Message chan model.MessageModel
|
||
var UDPAddressMap map[string]string
|
||
|
||
func UDPSendData(msg model.MessageModel, localFilePath string) error {
|
||
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
|
||
defer cancel()
|
||
Message = make(chan model.MessageModel)
|
||
_, port, err := net.SplitHostPort(UDPConn.LocalAddr().String())
|
||
if config.ServerInfo.UDPPort != port {
|
||
config.ServerInfo.UDPPort = port
|
||
config.Cfg.Section("server").Key("UDPPort").SetValue(port)
|
||
config.Cfg.SaveTo(config.SystemConfigInfo.ConfigPath)
|
||
}
|
||
p, err := strconv.Atoi(port)
|
||
srcAddr := &net.UDPAddr{
|
||
IP: net.IPv4zero, Port: p} //注意端口必须固定
|
||
addr := UDPAddressMap[msg.To]
|
||
ticket := msg.To
|
||
dstAddr, err := net.ResolveUDPAddr("udp", addr)
|
||
|
||
session, err := quic.DialContext(ctx, UDPConn, dstAddr, srcAddr.String(), quic_helper.GetClientTlsConfig(ticket), quic_helper.GetQUICConfig())
|
||
if err != nil {
|
||
if msg.Type == types.PERSONDOWNLOAD {
|
||
task := MyService.Download().GetDownloadById(msg.UUId)
|
||
task.Error = err.Error()
|
||
task.State = types.DOWNLOADERROR
|
||
MyService.Download().SetDownloadError(task)
|
||
}
|
||
if config.SystemConfigInfo.Analyse != "False" {
|
||
go MyService.Casa().PushConnectionStatus(msg.UUId, err.Error(), msg.From, msg.To, msg.Type)
|
||
}
|
||
|
||
return err
|
||
}
|
||
|
||
stream, err := session.OpenStreamSync(ctx)
|
||
if err != nil {
|
||
if msg.Type == types.PERSONDOWNLOAD {
|
||
task := MyService.Download().GetDownloadById(msg.UUId)
|
||
task.Error = err.Error()
|
||
task.State = types.DOWNLOADERROR
|
||
MyService.Download().SetDownloadError(task)
|
||
}
|
||
if config.SystemConfigInfo.Analyse != "False" {
|
||
go MyService.Casa().PushConnectionStatus(msg.UUId, err.Error(), msg.From, msg.To, msg.Type)
|
||
}
|
||
session.CloseWithError(1, err.Error())
|
||
return err
|
||
}
|
||
|
||
SayHello(stream, msg.To)
|
||
//TODO:发送
|
||
SendData(stream, msg)
|
||
SendFileData(stream, localFilePath, msg.To, msg.UUId, types.PERSONUPLOADDATA)
|
||
|
||
stream.Close()
|
||
if config.SystemConfigInfo.Analyse != "False" {
|
||
go MyService.Casa().PushConnectionStatus(msg.UUId, "OK", msg.From, msg.To, msg.Type)
|
||
}
|
||
return nil
|
||
}
|
||
|
||
func Dial(msg model.MessageModel, server bool) (m model.MessageModel, err error) {
|
||
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
|
||
defer cancel()
|
||
Message = make(chan model.MessageModel)
|
||
_, port, err := net.SplitHostPort(UDPConn.LocalAddr().String())
|
||
if config.ServerInfo.UDPPort != port {
|
||
config.ServerInfo.UDPPort = port
|
||
config.Cfg.Section("server").Key("UDPPort").SetValue(port)
|
||
config.Cfg.SaveTo(config.SystemConfigInfo.ConfigPath)
|
||
}
|
||
p, err := strconv.Atoi(port)
|
||
srcAddr := &net.UDPAddr{
|
||
IP: net.IPv4zero, Port: p} //注意端口必须固定
|
||
addr := UDPAddressMap[msg.To]
|
||
ticket := msg.To
|
||
if server {
|
||
addr = config.ServerInfo.Handshake + ":9527"
|
||
ticket = "bench"
|
||
}
|
||
dstAddr, err := net.ResolveUDPAddr("udp", addr)
|
||
|
||
//DialTCP在网络协议net上连接本地地址laddr和远端地址raddr。net必须是"udp"、"udp4"、"udp6"；如果laddr不是nil，将使用它作为本地地址，否则自动选择一个本地地址。
|
||
//(conn)UDPConn代表一个UDP网络连接，实现了Conn和PacketConn接口
|
||
|
||
session, err := quic.DialContext(ctx, UDPConn, dstAddr, srcAddr.String(), quic_helper.GetClientTlsConfig(ticket), quic_helper.GetQUICConfig())
|
||
if err != nil {
|
||
if msg.Type == types.PERSONDOWNLOAD {
|
||
task := MyService.Download().GetDownloadById(msg.UUId)
|
||
task.Error = err.Error()
|
||
task.State = types.DOWNLOADERROR
|
||
MyService.Download().SetDownloadError(task)
|
||
}
|
||
if config.SystemConfigInfo.Analyse != "False" {
|
||
go MyService.Casa().PushConnectionStatus(msg.UUId, err.Error(), msg.From, msg.To, msg.Type)
|
||
}
|
||
|
||
return m, err
|
||
}
|
||
|
||
stream, err := session.OpenStreamSync(ctx)
|
||
if err != nil {
|
||
if msg.Type == types.PERSONDOWNLOAD {
|
||
task := MyService.Download().GetDownloadById(msg.UUId)
|
||
task.Error = err.Error()
|
||
task.State = types.DOWNLOADERROR
|
||
MyService.Download().SetDownloadError(task)
|
||
}
|
||
if config.SystemConfigInfo.Analyse != "False" {
|
||
go MyService.Casa().PushConnectionStatus(msg.UUId, err.Error(), msg.From, msg.To, msg.Type)
|
||
}
|
||
session.CloseWithError(1, err.Error())
|
||
return m, err
|
||
}
|
||
|
||
SayHello(stream, msg.To)
|
||
|
||
SendData(stream, msg)
|
||
|
||
go ReadContent(stream)
|
||
result := <-Message
|
||
stream.Close()
|
||
if config.SystemConfigInfo.Analyse != "False" {
|
||
go MyService.Casa().PushConnectionStatus(msg.UUId, "OK", msg.From, msg.To, msg.Type)
|
||
}
|
||
return result, nil
|
||
}
|
||
|
||
func SayHello(stream quic.Stream, to string) {
|
||
msg := model.MessageModel{}
|
||
msg.Type = types.PERSONHELLO
|
||
msg.Data = "hello"
|
||
msg.To = to
|
||
msg.From = config.ServerInfo.Token
|
||
msg.UUId = uuid.NewV4().String()
|
||
SendData(stream, msg)
|
||
}
|
||
|
||
//发送数据
|
||
func SendData(stream quic.Stream, m model.MessageModel) {
|
||
b, _ := json.Marshal(m)
|
||
prefixLength := file.PrefixLength(len(b))
|
||
data := append(prefixLength, b...)
|
||
stream.Write(data)
|
||
}
|
||
|
||
//读取数据
|
||
func ReadContent(stream quic.Stream) {
|
||
for {
|
||
prefixByte := make([]byte, 6)
|
||
_, err := io.ReadFull(stream, prefixByte)
|
||
if err != nil {
|
||
fmt.Println(err)
|
||
time.Sleep(time.Second * 1)
|
||
for k, v := range CancelList {
|
||
tempPath := config.AppInfo.RootPath + "/temp" + "/" + v
|
||
fmt.Println(file.RMDir(tempPath))
|
||
delete(CancelList, k)
|
||
}
|
||
break
|
||
}
|
||
prefixLength, err := strconv.Atoi(string(prefixByte))
|
||
if err != nil {
|
||
fmt.Println(err)
|
||
break
|
||
}
|
||
messageByte := make([]byte, prefixLength)
|
||
_, err = io.ReadFull(stream, messageByte)
|
||
if err != nil {
|
||
fmt.Println(err)
|
||
break
|
||
}
|
||
m := model.MessageModel{}
|
||
err = json.Unmarshal(messageByte, &m)
|
||
if err != nil {
|
||
fmt.Println(err)
|
||
break
|
||
}
|
||
fmt.Println(m)
|
||
if m.Type == types.PERSONDOWNLOAD {
|
||
r := SaveFile(m, stream)
|
||
if r {
|
||
break
|
||
}
|
||
} else if m.Type == types.PERSONSUMMARY {
|
||
Summary(m, "download")
|
||
} else if m.Type == types.PERSONCONNECTION {
|
||
if len(m.Data.(string)) > 0 {
|
||
fmt.Println("设置ip", m.Data.(string))
|
||
UDPAddressMap[m.From] = m.Data.(string)
|
||
} else {
|
||
delete(UDPAddressMap, m.From)
|
||
}
|
||
// mi := model2.FriendModel{}
|
||
// mi.Avatar = config.UserInfo.Avatar
|
||
// mi.Profile = config.UserInfo.Description
|
||
// mi.NickName = config.UserInfo.NickName
|
||
// mi.Token = config.ServerInfo.Token
|
||
msg := model.MessageModel{}
|
||
msg.Type = types.PERSONHELLO
|
||
msg.Data = ""
|
||
msg.To = m.From
|
||
msg.From = config.ServerInfo.Token
|
||
msg.UUId = m.UUId
|
||
go Dial(msg, false)
|
||
Message <- m
|
||
break
|
||
} else if m.Type == types.PERSONGETIP {
|
||
notify := model2.AppNotify{}
|
||
notify.CustomId = m.From
|
||
if len(m.Data.(string)) == 0 {
|
||
if _, ok := UDPAddressMap[m.From]; ok {
|
||
notify.Type = types.NOTIFY_TYPE_PERSION_FIRNED_LEAVE
|
||
go MyService.Notify().SendText(notify)
|
||
}
|
||
delete(UDPAddressMap, m.From)
|
||
Message <- m
|
||
break
|
||
}
|
||
if _, ok := UDPAddressMap[m.From]; !ok {
|
||
notify.Type = types.NOTIFY_TYPE_PERSION_FIRNED_LIVE
|
||
go MyService.Notify().SendText(notify)
|
||
}
|
||
fmt.Println("设置ip", m.Data.(string))
|
||
UDPAddressMap[m.From] = m.Data.(string)
|
||
fmt.Println(config.ServerInfo.Token != m.From)
|
||
fmt.Println(strings.Split(m.Data.(string), ":")[0] == strings.Split(UDPAddressMap[config.ServerInfo.Token], ":")[0])
|
||
fmt.Println(strings.Split(m.Data.(string), ":")[0])
|
||
fmt.Println(strings.Split(UDPAddressMap[config.ServerInfo.Token], ":")[0])
|
||
if config.ServerInfo.Token != m.From && strings.Split(m.Data.(string), ":")[0] == strings.Split(UDPAddressMap[config.ServerInfo.Token], ":")[0] {
|
||
msg := model.MessageModel{}
|
||
msg.Type = types.PERSONINTERNALINSPECTION
|
||
msg.Data = ip_helper.GetDeviceAllIP(config.ServerInfo.UDPPort)
|
||
msg.To = m.From
|
||
msg.From = config.ServerInfo.Token
|
||
msg.UUId = m.UUId
|
||
go Dial(msg, true)
|
||
}
|
||
|
||
Message <- m
|
||
break
|
||
} else if m.Type == types.PERSONINTERNALINSPECTION {
|
||
fmt.Println("接收到反验证")
|
||
var ips []string
|
||
dataModelByte, _ := json.Marshal(m.Data)
|
||
err := json.Unmarshal(dataModelByte, &ips)
|
||
if err != nil {
|
||
fmt.Println(err)
|
||
break
|
||
}
|
||
go MyService.Friend().InternalInspection(ips, m.From)
|
||
Message <- m
|
||
break
|
||
} else {
|
||
|
||
Message <- m
|
||
}
|
||
}
|
||
Message <- model.MessageModel{}
|
||
}
|
||
|
||
func SendIPToServer() {
|
||
msg := model.MessageModel{}
|
||
msg.Type = types.PERSONHELLO
|
||
msg.Data = ""
|
||
msg.From = config.ServerInfo.Token
|
||
msg.To = config.ServerInfo.Token
|
||
msg.UUId = uuid.NewV4().String()
|
||
|
||
Dial(msg, true)
|
||
}
|
||
|
||
func LoopFriend() {
|
||
list := MyService.Friend().GetFriendList()
|
||
//list := MyService.Friend().GetFriendListRemote()
|
||
msg := model.MessageModel{}
|
||
msg.Type = types.PERSONGETIP
|
||
msg.Data = ""
|
||
msg.From = config.ServerInfo.Token
|
||
msg.To = config.ServerInfo.Token
|
||
msg.UUId = uuid.NewV4().String()
|
||
Dial(msg, true)
|
||
|
||
for i := 0; i < len(list); i++ {
|
||
if _, ok := UDPAddressMap[list[i].Token]; !ok {
|
||
msg := model.MessageModel{}
|
||
msg.Type = types.PERSONGETIP
|
||
msg.Data = ""
|
||
msg.From = config.ServerInfo.Token
|
||
msg.To = list[i].Token
|
||
msg.UUId = uuid.NewV4().String()
|
||
Dial(msg, true)
|
||
}
|
||
|
||
msg.Type = types.PERSONPING
|
||
msg.Data = ""
|
||
msg.From = config.ServerInfo.Token
|
||
msg.To = list[i].Token
|
||
msg.UUId = uuid.NewV4().String()
|
||
|
||
if v, ok := UDPAddressMap[list[i].Token]; ok {
|
||
if ip_helper.HasLocalIP(net.ParseIP(strings.Split(v, ":")[0])) {
|
||
msg.Data = ip_helper.GetDeviceAllIP(config.ServerInfo.UDPPort)
|
||
fmt.Println("判断为内网ip,设置自己的ip地址", msg.Data)
|
||
}
|
||
fmt.Println("ping的数据", UDPAddressMap[list[i].Token])
|
||
oldIP := UDPAddressMap[list[i].Token]
|
||
fmt.Println("old ip", oldIP)
|
||
data, err := Dial(msg, false)
|
||
if err != nil || reflect.DeepEqual(data, model.MessageModel{}) || len(data.Data.(string)) == 0 {
|
||
fmt.Println("ping失败", list[i].Token, err, data, UDPAddressMap[list[i].Token])
|
||
if oldIP == UDPAddressMap[list[i].Token] {
|
||
notify := model2.AppNotify{}
|
||
notify.CustomId = data.From
|
||
notify.Type = types.NOTIFY_TYPE_PERSION_FIRNED_LEAVE
|
||
go MyService.Notify().SendText(notify)
|
||
|
||
delete(UDPAddressMap, list[i].Token)
|
||
|
||
msg := model.MessageModel{}
|
||
msg.Type = types.PERSONGETIP
|
||
msg.Data = ""
|
||
msg.From = config.ServerInfo.Token
|
||
msg.To = list[i].Token
|
||
msg.UUId = uuid.NewV4().String()
|
||
Dial(msg, true)
|
||
}
|
||
}
|
||
}
|
||
go func(shareId string) {
|
||
user := MyService.Casa().GetUserInfoByShareId(shareId)
|
||
m := model2.FriendModel{}
|
||
m.Token = shareId
|
||
friend := MyService.Friend().GetFriendById(m)
|
||
if friend.Version != user.Version {
|
||
friend.Avatar = user.Avatar
|
||
friend.NickName = user.NickName
|
||
friend.Profile = user.Desc
|
||
friend.Version = user.Version
|
||
MyService.Friend().UpdateOrCreate(friend)
|
||
}
|
||
}(list[i].Token)
|
||
|
||
}
|
||
}
|
||
|
||
//file summary
|
||
func Summary(m model.MessageModel, t string) {
|
||
dataModel := model.FileSummaryModel{}
|
||
dataModelByte, _ := json.Marshal(m.Data)
|
||
err := json.Unmarshal(dataModelByte, &dataModel)
|
||
if err != nil {
|
||
fmt.Println(err)
|
||
}
|
||
|
||
task := MyService.Download().GetDownloadById(m.UUId)
|
||
|
||
task.State = types.DOWNLOADING
|
||
fullPath := path2.Join(task.LocalPath, task.Name)
|
||
|
||
if len(dataModel.Message) > 0 {
|
||
task.State = types.DOWNLOADERROR
|
||
task.Error = dataModel.Message
|
||
}
|
||
//The file already exists and the file is the same, no need to download
|
||
if t != "upload" && file.Exists(fullPath) && file.GetHashByPath(fullPath) == dataModel.Hash {
|
||
task.State = types.DOWNLOADFINISHED
|
||
go func(from, uuid string) {
|
||
m := model.MessageModel{}
|
||
m.Data = ""
|
||
m.From = config.ServerInfo.Token
|
||
m.To = from
|
||
m.Type = types.PERSONCANCEL
|
||
m.UUId = uuid
|
||
CancelList[uuid] = uuid
|
||
Dial(m, false)
|
||
}(task.From, task.UUID)
|
||
|
||
}
|
||
task.UUID = m.UUId
|
||
task.Name = dataModel.Name
|
||
task.Length = dataModel.Length
|
||
task.Size = dataModel.Size
|
||
task.BlockSize = dataModel.BlockSize
|
||
task.Hash = dataModel.Hash
|
||
task.Type = types.PERSONFILEDOWNLOAD
|
||
task.From = m.From
|
||
if t == "upload" {
|
||
task.Type = types.PERSONFILERECEIVEUPLOAD
|
||
}
|
||
MyService.Download().SaveDownload(task)
|
||
}
|
||
|
||
//Save file fragment
|
||
func SaveFile(m model.MessageModel, stream quic.Stream) bool {
|
||
dataModelByte, _ := json.Marshal(m.Data)
|
||
dataModel := model.TranFileModel{}
|
||
err := json.Unmarshal(dataModelByte, &dataModel)
|
||
if err != nil {
|
||
fmt.Println(err)
|
||
return false
|
||
}
|
||
|
||
dataLengthByte := make([]byte, 8)
|
||
_, err = io.ReadFull(stream, dataLengthByte)
|
||
if err != nil {
|
||
fmt.Println(err)
|
||
return false
|
||
}
|
||
dataLength, err := strconv.Atoi(string(dataLengthByte))
|
||
if err != nil {
|
||
fmt.Println(err)
|
||
return false
|
||
}
|
||
dataByte := make([]byte, dataLength)
|
||
_, err = io.ReadFull(stream, dataByte)
|
||
if err != nil {
|
||
fmt.Println(err)
|
||
return false
|
||
}
|
||
sum := md5.Sum(dataByte)
|
||
hash := hex.EncodeToString(sum[:])
|
||
if dataModel.Hash != hash {
|
||
fmt.Println("hash不匹配", hash, dataModel.Hash)
|
||
return false
|
||
}
|
||
tempPath := config.AppInfo.RootPath + "/temp" + "/" + m.UUId
|
||
file.IsNotExistMkDir(tempPath)
|
||
filepath := tempPath + "/" + strconv.Itoa(dataModel.Index)
|
||
_, err = os.Stat(filepath)
|
||
|
||
if os.IsNotExist(err) {
|
||
err = ioutil.WriteFile(filepath, dataByte, 0644)
|
||
task := model2.PersonDownloadDBModel{}
|
||
task.UUID = m.UUId
|
||
if err != nil {
|
||
task.Error = err.Error()
|
||
task.State = types.DOWNLOADERROR
|
||
MyService.Download().SetDownloadError(task)
|
||
}
|
||
|
||
} else {
|
||
if file.GetHashByPath(filepath) != dataModel.Hash {
|
||
os.Remove(filepath)
|
||
err = ioutil.WriteFile(filepath, dataByte, 0644)
|
||
task := model2.PersonDownloadDBModel{}
|
||
task.UUID = m.UUId
|
||
if err != nil {
|
||
task.Error = err.Error()
|
||
task.State = types.DOWNLOADERROR
|
||
MyService.Download().SetDownloadError(task)
|
||
}
|
||
}
|
||
}
|
||
|
||
files, err := ioutil.ReadDir(tempPath)
|
||
if err != nil {
|
||
fmt.Println(err)
|
||
return false
|
||
}
|
||
if len(files) >= dataModel.Length {
|
||
summary := MyService.Download().GetDownloadById(m.UUId)
|
||
summary.State = types.DOWNLOADFINISH
|
||
MyService.Download().EditDownloadState(summary)
|
||
fullPath := file.GetNoDuplicateFileName(path2.Join(summary.LocalPath, summary.Name))
|
||
file.SpliceFiles(tempPath, fullPath, dataModel.Length, 0)
|
||
if file.GetHashByPath(fullPath) == summary.Hash {
|
||
file.RMDir(tempPath)
|
||
summary.State = types.DOWNLOADFINISHED
|
||
MyService.Download().EditDownloadState(summary)
|
||
} else {
|
||
os.Remove(config.FileSettingInfo.DownloadDir + "/" + summary.Name)
|
||
|
||
summary.State = types.DOWNLOADERROR
|
||
summary.Error = "hash mismatch"
|
||
MyService.Download().SetDownloadError(summary)
|
||
}
|
||
|
||
return true
|
||
}
|
||
return false
|
||
}
|