Compare commits
16 Commits
Author | SHA1 | Date | |
---|---|---|---|
14cda04e06 | |||
47d93ffe0e | |||
3c84dd7702 | |||
dcc3baaf02 | |||
362930c5d5 | |||
![]() |
c6bd18ef9c | ||
9f57d6688b | |||
13d6041711 | |||
d1521c9704 | |||
20888a4e60 | |||
e4300d9282 | |||
12e4a064d6 | |||
2190896442 | |||
d1e67df750 | |||
e15a6424bb | |||
64d1c420a2 |
12
.github/workflows/go.yml
vendored
12
.github/workflows/go.yml
vendored
@@ -1,7 +1,7 @@
|
|||||||
# This workflow will build a golang project
|
# This workflow will build a golang project
|
||||||
# For more information see: https://docs.github.com/en/actions/automating-builds-and-tests/building-and-testing-go
|
# For more information see: https://docs.github.com/en/actions/automating-builds-and-tests/building-and-testing-go
|
||||||
|
|
||||||
name: Go
|
name: build this now
|
||||||
|
|
||||||
on:
|
on:
|
||||||
push:
|
push:
|
||||||
@@ -24,7 +24,11 @@ jobs:
|
|||||||
run: sudo apt-get update && sudo apt-get install -y libx11-dev libxcursor-dev libxrandr-dev libxinerama-dev libxi-dev libgl1-mesa-dev libglu1-mesa-dev libxxf86vm-dev
|
run: sudo apt-get update && sudo apt-get install -y libx11-dev libxcursor-dev libxrandr-dev libxinerama-dev libxi-dev libgl1-mesa-dev libglu1-mesa-dev libxxf86vm-dev
|
||||||
|
|
||||||
- name: Build
|
- name: Build
|
||||||
run: go build -v ./...
|
run: go build .
|
||||||
|
|
||||||
|
- name: Artifact
|
||||||
|
uses: actions/upload-artifact@v4
|
||||||
|
with:
|
||||||
|
name: pi-binary
|
||||||
|
path: pi
|
||||||
|
|
||||||
- name: Test
|
|
||||||
run: go test -v ./...
|
|
||||||
|
2
.gitignore
vendored
2
.gitignore
vendored
@@ -26,7 +26,7 @@ go.work.sum
|
|||||||
|
|
||||||
# env file
|
# env file
|
||||||
.env
|
.env
|
||||||
pi.json
|
pi.xml
|
||||||
pi
|
pi
|
||||||
# Editor/IDE
|
# Editor/IDE
|
||||||
# .idea/
|
# .idea/
|
||||||
|
82
README.md
82
README.md
@@ -3,12 +3,15 @@
|
|||||||
</center>
|
</center>
|
||||||
|
|
||||||
# π
|
# π
|
||||||
[](https://github.com/sunglocto/pi/actions/workflows/go.yml)
|
[](https://github.com/sunglocto/pi/actions/workflows/go.yml)
|
||||||
|
<img width="1050" height="632" alt="image" src="https://github.com/user-attachments/assets/a5a3a7ab-8a85-49f0-81e9-ae5b977e7455" />
|
||||||
|
|
||||||
## the XMPP client from hell
|
## the XMPP client from hell
|
||||||
|
> it's 10% code. 20% ai
|
||||||
|
|
||||||
Experimental and extremely weird XMPP client made with Go. No solicitors.
|
Experimental and extremely weird XMPP client written in Go. No solicitors.
|
||||||
|
|
||||||
pi is currently pre-pre-pre-pre alpha software which you should not use right now.
|
pi is currently pre-pre-pre-pre alpha software which you should not use as your primary XMPP client.
|
||||||
|
|
||||||
pi uses [Fyne](https://fyne.io) for the frontend and uses the [Oasis SDK](https://github.com/jjj333-p/oasis-sdk) for XMPP functionality.
|
pi uses [Fyne](https://fyne.io) for the frontend and uses the [Oasis SDK](https://github.com/jjj333-p/oasis-sdk) for XMPP functionality.
|
||||||
|
|
||||||
@@ -20,35 +23,27 @@ pi is an extremely opinionated client. It aims to have as little extra windows a
|
|||||||
|
|
||||||
When you launch pi, you will be greeted with a create account screen. You will then be able to enter your XMPP account details and then relaunch the application to log in.
|
When you launch pi, you will be greeted with a create account screen. You will then be able to enter your XMPP account details and then relaunch the application to log in.
|
||||||
|
|
||||||
If you want to add MUCs or DMs, you must configure the program. Here is the general idea:
|
If you want to add MUCs or DMs, you must configure the program by editing the pi.xml file. Here is an example configuration:
|
||||||
|
|
||||||
```json
|
```xml
|
||||||
{
|
<piConfig>
|
||||||
"Login": {
|
<Login>
|
||||||
"Host": "example.com:5222",
|
<Host>example.com:5222</Host>
|
||||||
"User": "user@example.com",
|
<User>user@example.com</User>
|
||||||
"Password": "123456",
|
<Password>123456789</Password>
|
||||||
"DisplayName": "user",
|
<DisplayName>sunglocto</DisplayName>
|
||||||
"NoTLS": false,
|
<TLSoff>false</TLSoff>
|
||||||
"StartTLS": true,
|
<StartTLS>true</StartTLS>
|
||||||
"Mucs": [
|
<MucsToJoin>room1@muc.example.com</MucsToJoin>
|
||||||
"room1@group.example.com",
|
<MucsToJoin>room2@muc.example.com</MucsToJoin>
|
||||||
"room2@group.example.com"
|
</Login>
|
||||||
]
|
<Notifications>true</Notifications>
|
||||||
},
|
</piConfig>
|
||||||
"DMs": [
|
|
||||||
"mike@example.com",
|
|
||||||
"louis@example.com"
|
|
||||||
],
|
|
||||||
"Notifications": false
|
|
||||||
}
|
|
||||||
```
|
```
|
||||||
|
|
||||||
Edit this file as necessary.
|
Currently joining and saving DM tabs is not supported, nor is getting avatars, reactions or encryption.
|
||||||
|
|
||||||
Currently joining and saving DM tabs is not supported, nor is getting avatars, reactions, encryption of media embed.
|
As of writing, pi supports basic message sending and receiving, replies and ~~file upload~~.
|
||||||
|
|
||||||
As of writing, pi supports basic message sending and receiving, replies and file upload.
|
|
||||||
|
|
||||||
|
|
||||||
## να χτίσω
|
## να χτίσω
|
||||||
@@ -64,21 +59,38 @@ git clone https://github.com/sunglocto/pi
|
|||||||
cd pi
|
cd pi
|
||||||
go mod tidy
|
go mod tidy
|
||||||
go build .
|
go build .
|
||||||
vim pi.json
|
|
||||||
./pi
|
./pi
|
||||||
```
|
```
|
||||||
> Uh, Windows???
|
> Uh, Windows???
|
||||||
|
|
||||||
Eventually. Don't count on it.
|
Eventually. Don't count on it.
|
||||||
|
Fyne has first-class support for Windows and none of my dependencies are platform dependent. I've built this app for Android before. If you compile it, it will most likely work with no issues.
|
||||||
|
|
||||||
Static executable snapshots are also provided for GNU/Linux systems.
|
Static executable snapshots are also provided for GNU/Linux systems, and CI runs on every commit, producing a binary on every successful build. You're welcome.
|
||||||
|
|
||||||
## χρήση
|
|
||||||
(usage)
|
|
||||||
|
|
||||||
TODO
|
## υποστήριξη
|
||||||
|
(support)
|
||||||
|
|
||||||
# επιπλέον
|
You can file an issue and explain the problem you are having.
|
||||||
|
|
||||||
|
If you would like a more instant method of communication, join the [pi XMPP room.](xmpp:pi@room.sunglocto.net?join)
|
||||||
|
|
||||||
|
## μαρτυρίες
|
||||||
|
(testimonials)
|
||||||
|
From fellow insane and schizophrenic XMPP users:
|
||||||
|
|
||||||
|
> anyways this is your "just IM" client things ig.
|
||||||
|
|
||||||
|
> this looks like shit
|
||||||
|
|
||||||
|
> fyne is the best UI toolkit (sarcastic)
|
||||||
|
|
||||||
|
> i am going to explode you
|
||||||
|
|
||||||
|
> pi devstream when
|
||||||
|
|
||||||
|
## επιπλέον
|
||||||
(extra)
|
(extra)
|
||||||
|
|
||||||
Pi version numbers are the digits of Pi followed by a letter indicating the phase of development the program is in.
|
Pi version numbers are the digits of Pi followed by a letter indicating the phase of development the program is in.
|
||||||
@@ -91,6 +103,6 @@ Is the third version produced in the alpha phase.
|
|||||||
|
|
||||||
The digits of Pi will reset back to `3` when moving to a new phase.
|
The digits of Pi will reset back to `3` when moving to a new phase.
|
||||||
|
|
||||||
If the number gets too long, it will reset to one digit of 2π. Once that gets to long, it will be digits of 3π and etc.
|
If the number gets too long, it will reset to one digit of 2π. Once that gets too long, it will be digits of 3π and etc.
|
||||||
|
|
||||||
Named after [Psi](https://github.com/psi-im/psi).
|
Named after [Psi](https://github.com/psi-im/psi).
|
||||||
|
2
go.mod
2
go.mod
@@ -5,7 +5,6 @@ go 1.24.5
|
|||||||
require (
|
require (
|
||||||
fyne.io/fyne/v2 v2.6.2
|
fyne.io/fyne/v2 v2.6.2
|
||||||
fyne.io/x/fyne v0.0.0-20250418202416-58a230ad1acb
|
fyne.io/x/fyne v0.0.0-20250418202416-58a230ad1acb
|
||||||
github.com/mbaklor/fyne-catppuccin v0.0.2
|
|
||||||
mellium.im/xmpp v0.22.0
|
mellium.im/xmpp v0.22.0
|
||||||
pain.agency/oasis-sdk v0.0.0-20250805052243-df6be3f9f629
|
pain.agency/oasis-sdk v0.0.0-20250805052243-df6be3f9f629
|
||||||
)
|
)
|
||||||
@@ -13,7 +12,6 @@ require (
|
|||||||
require (
|
require (
|
||||||
fyne.io/systray v1.11.0 // indirect
|
fyne.io/systray v1.11.0 // indirect
|
||||||
github.com/BurntSushi/toml v1.5.0 // indirect
|
github.com/BurntSushi/toml v1.5.0 // indirect
|
||||||
github.com/catppuccin/go v0.3.0 // indirect
|
|
||||||
github.com/davecgh/go-spew v1.1.1 // indirect
|
github.com/davecgh/go-spew v1.1.1 // indirect
|
||||||
github.com/fredbi/uri v1.1.0 // indirect
|
github.com/fredbi/uri v1.1.0 // indirect
|
||||||
github.com/fsnotify/fsnotify v1.9.0 // indirect
|
github.com/fsnotify/fsnotify v1.9.0 // indirect
|
||||||
|
4
go.sum
4
go.sum
@@ -6,8 +6,6 @@ fyne.io/x/fyne v0.0.0-20250418202416-58a230ad1acb h1:2BazNmb/kwgqRdvE9L+NgW8sfoW
|
|||||||
fyne.io/x/fyne v0.0.0-20250418202416-58a230ad1acb/go.mod h1:u3LF1EkElytjOT8OHxft16trctGndF9qpsoH6YIDOUU=
|
fyne.io/x/fyne v0.0.0-20250418202416-58a230ad1acb/go.mod h1:u3LF1EkElytjOT8OHxft16trctGndF9qpsoH6YIDOUU=
|
||||||
github.com/BurntSushi/toml v1.5.0 h1:W5quZX/G/csjUnuI8SUYlsHs9M38FC7znL0lIO+DvMg=
|
github.com/BurntSushi/toml v1.5.0 h1:W5quZX/G/csjUnuI8SUYlsHs9M38FC7znL0lIO+DvMg=
|
||||||
github.com/BurntSushi/toml v1.5.0/go.mod h1:ukJfTF/6rtPPRCnwkur4qwRxa8vTRFBF0uk2lLoLwho=
|
github.com/BurntSushi/toml v1.5.0/go.mod h1:ukJfTF/6rtPPRCnwkur4qwRxa8vTRFBF0uk2lLoLwho=
|
||||||
github.com/catppuccin/go v0.3.0 h1:d+0/YicIq+hSTo5oPuRi5kOpqkVA5tAsU6dNhvRu+aY=
|
|
||||||
github.com/catppuccin/go v0.3.0/go.mod h1:8IHJuMGaUUjQM82qBrGNBv7LFq6JI3NnQCF6MOlZjpc=
|
|
||||||
github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
|
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/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
|
||||||
github.com/felixge/fgprof v0.9.3 h1:VvyZxILNuCiUCSXtPtYmmtGvb65nqXh2QFWc0Wpf2/g=
|
github.com/felixge/fgprof v0.9.3 h1:VvyZxILNuCiUCSXtPtYmmtGvb65nqXh2QFWc0Wpf2/g=
|
||||||
@@ -50,8 +48,6 @@ github.com/jsummers/gobmp v0.0.0-20230614200233-a9de23ed2e25 h1:YLvr1eE6cdCqjOe9
|
|||||||
github.com/jsummers/gobmp v0.0.0-20230614200233-a9de23ed2e25/go.mod h1:kLgvv7o6UM+0QSf0QjAse3wReFDsb9qbZJdfexWlrQw=
|
github.com/jsummers/gobmp v0.0.0-20230614200233-a9de23ed2e25/go.mod h1:kLgvv7o6UM+0QSf0QjAse3wReFDsb9qbZJdfexWlrQw=
|
||||||
github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
|
github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
|
||||||
github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
|
github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
|
||||||
github.com/mbaklor/fyne-catppuccin v0.0.2 h1:yMNnYkmFwjKJkFQvCd1uNKZDs07ZC85wTkedTIGcViE=
|
|
||||||
github.com/mbaklor/fyne-catppuccin v0.0.2/go.mod h1:ZBIy4dV1yMj+7oEaZYkXm5OfYESmXuPWwNcuUmD1Njo=
|
|
||||||
github.com/nfnt/resize v0.0.0-20180221191011-83c6a9932646 h1:zYyBkD/k9seD2A7fsi6Oo2LfFZAehjjQMERAvZLEDnQ=
|
github.com/nfnt/resize v0.0.0-20180221191011-83c6a9932646 h1:zYyBkD/k9seD2A7fsi6Oo2LfFZAehjjQMERAvZLEDnQ=
|
||||||
github.com/nfnt/resize v0.0.0-20180221191011-83c6a9932646/go.mod h1:jpp1/29i3P1S/RLdc7JQKbRpFeM1dOBd8T9ki5s+AY8=
|
github.com/nfnt/resize v0.0.0-20180221191011-83c6a9932646/go.mod h1:jpp1/29i3P1S/RLdc7JQKbRpFeM1dOBd8T9ki5s+AY8=
|
||||||
github.com/nicksnyder/go-i18n/v2 v2.6.0 h1:C/m2NNWNiTB6SK4Ao8df5EWm3JETSTIGNXBpMJTxzxQ=
|
github.com/nicksnyder/go-i18n/v2 v2.6.0 h1:C/m2NNWNiTB6SK4Ao8df5EWm3JETSTIGNXBpMJTxzxQ=
|
||||||
|
490
main.go
490
main.go
@@ -1,17 +1,17 @@
|
|||||||
package main
|
package main
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"encoding/json"
|
//core - required
|
||||||
"encoding/xml"
|
"encoding/xml"
|
||||||
"fmt"
|
"fmt"
|
||||||
"image/color"
|
"image/color"
|
||||||
"io"
|
"io"
|
||||||
_ "io/fs"
|
|
||||||
"log"
|
"log"
|
||||||
"net/url"
|
"net/url"
|
||||||
"os"
|
|
||||||
"strings"
|
"strings"
|
||||||
|
"time"
|
||||||
|
|
||||||
|
// gui - required
|
||||||
"fyne.io/fyne/v2"
|
"fyne.io/fyne/v2"
|
||||||
"fyne.io/fyne/v2/app"
|
"fyne.io/fyne/v2/app"
|
||||||
"fyne.io/fyne/v2/canvas"
|
"fyne.io/fyne/v2/canvas"
|
||||||
@@ -20,13 +20,23 @@ import (
|
|||||||
"fyne.io/fyne/v2/storage"
|
"fyne.io/fyne/v2/storage"
|
||||||
"fyne.io/fyne/v2/theme"
|
"fyne.io/fyne/v2/theme"
|
||||||
"fyne.io/fyne/v2/widget"
|
"fyne.io/fyne/v2/widget"
|
||||||
catppuccin "github.com/mbaklor/fyne-catppuccin"
|
|
||||||
|
// xmpp - required
|
||||||
|
"mellium.im/xmpp/disco"
|
||||||
"mellium.im/xmpp/jid"
|
"mellium.im/xmpp/jid"
|
||||||
"mellium.im/xmpp/muc"
|
"mellium.im/xmpp/muc"
|
||||||
oasisSdk "pain.agency/oasis-sdk"
|
oasisSdk "pain.agency/oasis-sdk"
|
||||||
|
|
||||||
|
// gui - optional
|
||||||
|
// catppuccin "github.com/mbaklor/fyne-catppuccin"
|
||||||
|
adwaita "fyne.io/x/fyne/theme"
|
||||||
|
// TODO: integrated theme switcher
|
||||||
)
|
)
|
||||||
|
|
||||||
var version string = "3.1a"
|
var version string = "3.1a"
|
||||||
|
var statBar widget.Label
|
||||||
|
var chatInfo fyne.Container
|
||||||
|
var chatSidebar fyne.Container
|
||||||
|
|
||||||
// by sunglocto
|
// by sunglocto
|
||||||
// license AGPL
|
// license AGPL
|
||||||
@@ -46,6 +56,7 @@ type MucTab struct {
|
|||||||
Messages []Message
|
Messages []Message
|
||||||
Scroller *widget.List
|
Scroller *widget.List
|
||||||
isMuc bool
|
isMuc bool
|
||||||
|
Muc *muc.Channel
|
||||||
}
|
}
|
||||||
|
|
||||||
type piConfig struct {
|
type piConfig struct {
|
||||||
@@ -68,7 +79,7 @@ var connection bool = true
|
|||||||
type myTheme struct{}
|
type myTheme struct{}
|
||||||
|
|
||||||
func (m myTheme) Color(name fyne.ThemeColorName, variant fyne.ThemeVariant) color.Color {
|
func (m myTheme) Color(name fyne.ThemeColorName, variant fyne.ThemeVariant) color.Color {
|
||||||
return catppuccin.New().Color(name, variant)
|
return adwaita.AdwaitaTheme().Color(name, variant)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m myTheme) Icon(name fyne.ThemeIconName) fyne.Resource {
|
func (m myTheme) Icon(name fyne.ThemeIconName) fyne.Resource {
|
||||||
@@ -114,8 +125,8 @@ func addChatTab(isMuc bool, chatJid jid.JID, nick string) {
|
|||||||
author.TextStyle.Bold = true
|
author.TextStyle.Bold = true
|
||||||
content := widget.NewRichTextWithText("content")
|
content := widget.NewRichTextWithText("content")
|
||||||
content.Wrapping = fyne.TextWrapWord
|
content.Wrapping = fyne.TextWrapWord
|
||||||
icon := theme.FileImageIcon()
|
icon := theme.FileVideoIcon()
|
||||||
btn := widget.NewButtonWithIcon("View image", icon, func() {
|
btn := widget.NewButtonWithIcon("View media", icon, func() {
|
||||||
|
|
||||||
})
|
})
|
||||||
return container.NewVBox(author, content, btn)
|
return container.NewVBox(author, content, btn)
|
||||||
@@ -131,7 +142,20 @@ func addChatTab(isMuc bool, chatJid jid.JID, nick string) {
|
|||||||
btn.Hidden = false
|
btn.Hidden = false
|
||||||
btn.OnTapped = func() {
|
btn.OnTapped = func() {
|
||||||
fyne.Do(func() {
|
fyne.Do(func() {
|
||||||
u, _ := storage.ParseURI(tabData.Messages[i].ImageURL)
|
u, err := storage.ParseURI(tabData.Messages[i].ImageURL)
|
||||||
|
if err != nil {
|
||||||
|
dialog.ShowError(err, w)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
if strings.HasSuffix(tabData.Messages[i].ImageURL, "mp4") {
|
||||||
|
url, err := url.Parse(tabData.Messages[i].ImageURL)
|
||||||
|
if err != nil {
|
||||||
|
dialog.ShowError(err, w)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
a.OpenURL(url)
|
||||||
|
return
|
||||||
|
}
|
||||||
image := canvas.NewImageFromURI(u)
|
image := canvas.NewImageFromURI(u)
|
||||||
image.FillMode = canvas.ImageFillOriginal
|
image.FillMode = canvas.ImageFillOriginal
|
||||||
dialog.ShowCustom("Image", "Close", image, w)
|
dialog.ShowCustom("Image", "Close", image, w)
|
||||||
@@ -142,14 +166,14 @@ func addChatTab(isMuc bool, chatJid jid.JID, nick string) {
|
|||||||
lines := strings.Split(msgContent, "\n")
|
lines := strings.Split(msgContent, "\n")
|
||||||
for i, line := range lines {
|
for i, line := range lines {
|
||||||
if strings.HasPrefix(line, ">") {
|
if strings.HasPrefix(line, ">") {
|
||||||
lines[i] = "\n" + line + "\n"
|
lines[i] = fmt.Sprintf("\n %s \n", line)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
msgContent = strings.Join(lines, "\n")
|
msgContent = strings.Join(lines, "\n")
|
||||||
|
|
||||||
content.ParseMarkdown(msgContent)
|
content.ParseMarkdown(msgContent)
|
||||||
if tabData.Messages[i].ReplyID != "PICLIENT:UNAVAILABLE" {
|
if tabData.Messages[i].ReplyID != "PICLIENT:UNAVAILABLE" {
|
||||||
author.SetText(fmt.Sprintf("%s ↳ %s", tabData.Messages[i].Author, jid.MustParse(tabData.Messages[i].ReplyID).Resourcepart()))
|
author.SetText(fmt.Sprintf("%s > %s", tabData.Messages[i].Author, jid.MustParse(tabData.Messages[i].Raw.Reply.To).Resourcepart()))
|
||||||
} else {
|
} else {
|
||||||
author.SetText(tabData.Messages[i].Author)
|
author.SetText(tabData.Messages[i].Author)
|
||||||
}
|
}
|
||||||
@@ -160,6 +184,8 @@ func addChatTab(isMuc bool, chatJid jid.JID, nick string) {
|
|||||||
selectedId = id
|
selectedId = id
|
||||||
}
|
}
|
||||||
|
|
||||||
|
scroller.CreateItem()
|
||||||
|
|
||||||
tabData.Scroller = scroller
|
tabData.Scroller = scroller
|
||||||
|
|
||||||
chatTabs[mucJidStr] = tabData
|
chatTabs[mucJidStr] = tabData
|
||||||
@@ -169,81 +195,97 @@ func addChatTab(isMuc bool, chatJid jid.JID, nick string) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func dropToSignInPage(reason string) {
|
func dropToSignInPage(reason string) {
|
||||||
a = app.New()
|
w = a.NewWindow("Welcome to Pi")
|
||||||
w = a.NewWindow("Welcome to Pi")
|
w.Resize(fyne.NewSize(500, 500))
|
||||||
w.Resize(fyne.NewSize(500, 500))
|
rt := widget.NewRichTextFromMarkdown("# Welcome to pi\nIt appears you do not have a valid account configured. Let's create one!")
|
||||||
rt := widget.NewRichTextFromMarkdown("# Welcome to pi\nIt appears you do not have a valid account configured. Let's create one!")
|
footer := widget.NewRichTextFromMarkdown(fmt.Sprintf("Reason for being dropped to the sign-in page:\n\n```%s```", reason))
|
||||||
footer := widget.NewRichTextFromMarkdown(fmt.Sprintf("Reason for being dropped to the sign-in page:\n\n```%s```", reason))
|
userEntry := widget.NewEntry()
|
||||||
userEntry := widget.NewEntry()
|
userEntry.SetPlaceHolder("Your JID")
|
||||||
userEntry.SetPlaceHolder("Your JID")
|
serverEntry := widget.NewEntry()
|
||||||
serverEntry := widget.NewEntry()
|
serverEntry.SetPlaceHolder("Server and port")
|
||||||
serverEntry.SetPlaceHolder("Server and port")
|
passwordEntry := widget.NewPasswordEntry()
|
||||||
passwordEntry := widget.NewPasswordEntry()
|
passwordEntry.SetPlaceHolder("Your Password")
|
||||||
passwordEntry.SetPlaceHolder("Your Password")
|
nicknameEntry := widget.NewEntry()
|
||||||
nicknameEntry := widget.NewEntry()
|
nicknameEntry.SetPlaceHolder("Your Nickname")
|
||||||
nicknameEntry.SetPlaceHolder("Your Nickname")
|
|
||||||
|
|
||||||
userView := widget.NewFormItem("", userEntry)
|
userView := widget.NewFormItem("", userEntry)
|
||||||
serverView := widget.NewFormItem("", serverEntry)
|
serverView := widget.NewFormItem("", serverEntry)
|
||||||
passwordView := widget.NewFormItem("", passwordEntry)
|
passwordView := widget.NewFormItem("", passwordEntry)
|
||||||
nicknameView := widget.NewFormItem("", nicknameEntry)
|
nicknameView := widget.NewFormItem("", nicknameEntry)
|
||||||
items := []*widget.FormItem{
|
items := []*widget.FormItem{
|
||||||
serverView,
|
serverView,
|
||||||
userView,
|
userView,
|
||||||
passwordView,
|
passwordView,
|
||||||
nicknameView,
|
nicknameView,
|
||||||
}
|
}
|
||||||
|
|
||||||
btn := widget.NewButton("Create an account", func() {
|
btn := widget.NewButton("Create an account", func() {
|
||||||
dialog.ShowForm("Create an account", "Create", "Dismiss", items, func(b bool) {
|
dialog.ShowForm("Create an account", "Create", "Dismiss", items, func(b bool) {
|
||||||
if b {
|
if b {
|
||||||
config := piConfig{}
|
config := piConfig{}
|
||||||
config.Login.Host = serverEntry.Text
|
config.Login.Host = serverEntry.Text
|
||||||
config.Login.User = userEntry.Text
|
config.Login.User = userEntry.Text
|
||||||
config.Login.Password = passwordEntry.Text
|
config.Login.Password = passwordEntry.Text
|
||||||
config.Login.DisplayName = nicknameEntry.Text
|
config.Login.DisplayName = nicknameEntry.Text
|
||||||
config.Notifications = true
|
config.Notifications = true
|
||||||
|
config.Login.MucsToJoin = append(config.Login.MucsToJoin, "ringen@muc.isekai.rocks") // DEBUG
|
||||||
|
|
||||||
bytes, err := json.MarshalIndent(config, "", " ")
|
bytes, err := xml.MarshalIndent(config, "", "\t")
|
||||||
if err != nil {
|
if err != nil {
|
||||||
dialog.ShowError(err, w)
|
dialog.ShowError(err, w)
|
||||||
return
|
return
|
||||||
}
|
|
||||||
|
|
||||||
os.Create("pi.json")
|
|
||||||
os.WriteFile("pi.json", bytes, os.FileMode(os.O_RDWR)) // TODO: See if this works on non-unix like systems
|
|
||||||
a.SendNotification(fyne.NewNotification("Done", "Relaunch the application"))
|
|
||||||
w.Close()
|
|
||||||
}
|
}
|
||||||
}, w)
|
|
||||||
})
|
writer, err := a.Storage().Create("pi.xml")
|
||||||
btn2 := widget.NewButton("Close pi", func() {
|
if err != nil {
|
||||||
w.Close()
|
dialog.ShowError(err, w)
|
||||||
})
|
return
|
||||||
w.SetContent(container.NewVBox(rt, btn, btn2,footer))
|
}
|
||||||
w.ShowAndRun()
|
defer writer.Close()
|
||||||
|
_, err = writer.Write(bytes)
|
||||||
|
if err != nil {
|
||||||
|
dialog.ShowError(err, w)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
a.SendNotification(fyne.NewNotification("Done", "Relaunch the application"))
|
||||||
|
a.Quit()
|
||||||
|
//w.Close()
|
||||||
|
}
|
||||||
|
}, w)
|
||||||
|
})
|
||||||
|
btn2 := widget.NewButton("Close pi", func() {
|
||||||
|
w.Close()
|
||||||
|
})
|
||||||
|
w.SetContent(container.NewVBox(rt, btn, btn2, footer))
|
||||||
|
w.ShowAndRun()
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func main() {
|
func main() {
|
||||||
|
muc.Since(time.Now())
|
||||||
config = piConfig{}
|
config = piConfig{}
|
||||||
|
a = app.NewWithID("pi-ism")
|
||||||
|
reader, err := a.Storage().Open("pi.xml")
|
||||||
|
if err != nil {
|
||||||
|
dropToSignInPage(err.Error())
|
||||||
|
return
|
||||||
|
}
|
||||||
|
defer reader.Close()
|
||||||
|
|
||||||
bytes, err := os.ReadFile("./pi.json")
|
bytes, err := io.ReadAll(reader)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
dropToSignInPage(err.Error())
|
dropToSignInPage(err.Error())
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
err = xml.Unmarshal(bytes, &config)
|
||||||
err = json.Unmarshal(bytes, &config)
|
if err != nil {
|
||||||
if err != nil {
|
dropToSignInPage(fmt.Sprintf("Your pi.xml file is invalid:\n%s", err.Error()))
|
||||||
dropToSignInPage(fmt.Sprintf("Your pi.json file is invalid:\n%s", err.Error()))
|
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
login = config.Login
|
|
||||||
DMs = config.DMs
|
DMs = config.DMs
|
||||||
|
login = config.Login
|
||||||
notifications = config.Notifications
|
notifications = config.Notifications
|
||||||
|
|
||||||
client, err := oasisSdk.CreateClient(
|
client, err := oasisSdk.CreateClient(
|
||||||
@@ -266,8 +308,10 @@ func main() {
|
|||||||
for j, v := range s {
|
for j, v := range s {
|
||||||
_, err := url.Parse(v)
|
_, err := url.Parse(v)
|
||||||
if err == nil && strings.HasPrefix(v, "https://") {
|
if err == nil && strings.HasPrefix(v, "https://") {
|
||||||
img = v
|
|
||||||
s[j] = fmt.Sprintf("[%s](%s)", v, v)
|
s[j] = fmt.Sprintf("[%s](%s)", v, v)
|
||||||
|
if strings.HasSuffix(v, ".png") || strings.HasSuffix(v, ".jpg") || strings.HasSuffix(v, ".jpeg") || strings.HasSuffix(v, ".webp") || strings.HasSuffix(v, ".mp4") {
|
||||||
|
img = v
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
lines[i] = strings.Join(s, " ")
|
lines[i] = strings.Join(s, " ")
|
||||||
@@ -298,14 +342,30 @@ func main() {
|
|||||||
})
|
})
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
func(client *oasisSdk.XmppClient, _ *muc.Channel, msg *oasisSdk.XMPPChatMessage) {
|
func(client *oasisSdk.XmppClient, muc *muc.Channel, msg *oasisSdk.XMPPChatMessage) {
|
||||||
|
// HACK: IGNORING ALL MESSAGES FROM CLASSIC MUC HISTORY IN PREPARATION OF MAM SUPPORT
|
||||||
|
ignore := false
|
||||||
|
correction := false
|
||||||
|
for _, v := range msg.Unknown {
|
||||||
|
if v.XMLName.Local == "delay" { // CLasic history message
|
||||||
|
//ignore = true
|
||||||
|
//fmt.Println("ignoring!")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, v := range msg.Unknown {
|
||||||
|
if v.XMLName.Local == "replace" {
|
||||||
|
correction = true
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
var ImageID string = ""
|
var ImageID string = ""
|
||||||
mucJidStr := msg.From.Bare().String()
|
mucJidStr := msg.From.Bare().String()
|
||||||
if tab, ok := chatTabs[mucJidStr]; ok {
|
if tab, ok := chatTabs[mucJidStr]; ok {
|
||||||
|
chatTabs[mucJidStr].Muc = muc
|
||||||
str := *msg.CleanedBody
|
str := *msg.CleanedBody
|
||||||
if notifications {
|
if !ignore && notifications {
|
||||||
if strings.Contains(str, login.DisplayName) || (msg.Reply != nil && strings.Contains(msg.Reply.To, login.DisplayName)) {
|
if !correction && strings.Contains(str, login.DisplayName) || (msg.Reply != nil && strings.Contains(msg.Reply.To, login.DisplayName)) {
|
||||||
a.SendNotification(fyne.NewNotification(fmt.Sprintf("Mentioned in %s", mucJidStr), str))
|
a.SendNotification(fyne.NewNotification(fmt.Sprintf("Mentioned in %s", mucJidStr), str))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -317,7 +377,7 @@ func main() {
|
|||||||
_, err := url.Parse(v)
|
_, err := url.Parse(v)
|
||||||
if err == nil && strings.HasPrefix(v, "https://") {
|
if err == nil && strings.HasPrefix(v, "https://") {
|
||||||
s[j] = fmt.Sprintf("[%s](%s)", v, v)
|
s[j] = fmt.Sprintf("[%s](%s)", v, v)
|
||||||
if strings.HasSuffix(v, ".png") || strings.HasSuffix(v, ".jp") || strings.HasSuffix(v, ".webp") {
|
if strings.HasSuffix(v, ".png") || strings.HasSuffix(v, ".jpg") || strings.HasSuffix(v, ".jpeg") || strings.HasSuffix(v, ".webp") || strings.HasSuffix(v, ".mp4") {
|
||||||
ImageID = v
|
ImageID = v
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -334,15 +394,30 @@ func main() {
|
|||||||
} else {
|
} else {
|
||||||
replyID = msg.Reply.To
|
replyID = msg.Reply.To
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if correction {
|
||||||
|
for i := len(tab.Messages)-1; i > 0; i-- {
|
||||||
|
if tab.Messages[i].Raw.From.String() == msg.From.String() {
|
||||||
|
tab.Messages[i].Content = *msg.CleanedBody + " (edited)"
|
||||||
|
fyne.Do(func() {
|
||||||
|
tab.Scroller.Refresh()
|
||||||
|
})
|
||||||
|
return
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
myMessage := Message{
|
myMessage := Message{
|
||||||
Author: msg.From.Resourcepart(),
|
Author: msg.From.Resourcepart(),
|
||||||
Content: str,
|
Content: str,
|
||||||
ID: msg.ID,
|
ID: msg.ID,
|
||||||
ReplyID: replyID,
|
ReplyID: replyID,
|
||||||
Raw: *msg,
|
Raw: *msg,
|
||||||
ImageURL: ImageID,
|
ImageURL: ImageID,
|
||||||
}
|
}
|
||||||
tab.Messages = append(tab.Messages, myMessage)
|
if !ignore {
|
||||||
|
tab.Messages = append(tab.Messages, myMessage)
|
||||||
|
}
|
||||||
fyne.Do(func() {
|
fyne.Do(func() {
|
||||||
tab.Scroller.Refresh()
|
tab.Scroller.Refresh()
|
||||||
if scrollDownOnNewMessage {
|
if scrollDownOnNewMessage {
|
||||||
@@ -353,12 +428,27 @@ func main() {
|
|||||||
},
|
},
|
||||||
func(_ *oasisSdk.XmppClient, from jid.JID, state oasisSdk.ChatState) {
|
func(_ *oasisSdk.XmppClient, from jid.JID, state oasisSdk.ChatState) {
|
||||||
switch state {
|
switch state {
|
||||||
case oasisSdk.ChatStateActive:
|
|
||||||
case oasisSdk.ChatStateComposing:
|
case oasisSdk.ChatStateComposing:
|
||||||
|
fyne.Do(func() {
|
||||||
|
statBar.SetText(fmt.Sprintf("%s is typing...", from.Resourcepart()))
|
||||||
|
})
|
||||||
case oasisSdk.ChatStatePaused:
|
case oasisSdk.ChatStatePaused:
|
||||||
|
|
||||||
|
fyne.Do(func() {
|
||||||
|
statBar.SetText(fmt.Sprintf("%s has stoped typing.", from.Resourcepart()))
|
||||||
|
})
|
||||||
case oasisSdk.ChatStateInactive:
|
case oasisSdk.ChatStateInactive:
|
||||||
|
fyne.Do(func() {
|
||||||
|
statBar.SetText(fmt.Sprintf("%s is idle", from.Resourcepart()))
|
||||||
|
})
|
||||||
case oasisSdk.ChatStateGone:
|
case oasisSdk.ChatStateGone:
|
||||||
|
fyne.Do(func() {
|
||||||
|
statBar.SetText(fmt.Sprintf("%s is gone", from.Resourcepart()))
|
||||||
|
})
|
||||||
default:
|
default:
|
||||||
|
fyne.Do(func() {
|
||||||
|
statBar.SetText(fmt.Sprint("Unknown state: ", state))
|
||||||
|
})
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
func(_ *oasisSdk.XmppClient, from jid.JID, id string) {
|
func(_ *oasisSdk.XmppClient, from jid.JID, id string) {
|
||||||
@@ -368,11 +458,33 @@ func main() {
|
|||||||
fmt.Printf("%s has seen %s", from.String(), id)
|
fmt.Printf("%s has seen %s", from.String(), id)
|
||||||
},
|
},
|
||||||
)
|
)
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatalln("Could not create client - " + err.Error())
|
log.Fatalln("Could not create client - " + err.Error())
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
client.Session.Serve(xmpp.HandlerFunc(func(t xmlstream.TokenReadEncoder, start *xml.StartElement) error {
|
||||||
|
d := xml.NewTokenDecoder(t)
|
||||||
|
|
||||||
|
// Ignore anything that's not a message.
|
||||||
|
if start.Name.Local != "message" {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
msg := struct {
|
||||||
|
stanza.Message
|
||||||
|
Body string `xml:"body"`
|
||||||
|
}{}
|
||||||
|
err := d.DecodeElement(&msg, start)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
if msg.Body != "" {
|
||||||
|
log.Println("Got message: %q", msg.Body)
|
||||||
|
}
|
||||||
|
return nil
|
||||||
|
}))
|
||||||
|
*/
|
||||||
go func() {
|
go func() {
|
||||||
for connection {
|
for connection {
|
||||||
err = client.Connect()
|
err = client.Connect()
|
||||||
@@ -400,7 +512,7 @@ func main() {
|
|||||||
entry.OnChanged = func(s string) {
|
entry.OnChanged = func(s string) {
|
||||||
}
|
}
|
||||||
|
|
||||||
sendbtn := widget.NewButton("Send", func() {
|
SendCallback := func() {
|
||||||
text := entry.Text
|
text := entry.Text
|
||||||
if tabs.Selected() == nil || tabs.Selected().Content == nil {
|
if tabs.Selected() == nil || tabs.Selected().Content == nil {
|
||||||
return
|
return
|
||||||
@@ -426,14 +538,13 @@ func main() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
go func() {
|
go func() {
|
||||||
//TODO: Fix message hack until jjj adds message sending
|
|
||||||
if replying {
|
if replying {
|
||||||
m := chatTabs[activeMucJid].Messages[selectedId].Raw
|
m := chatTabs[activeMucJid].Messages[selectedId].Raw
|
||||||
client.ReplyToEvent(&m, text)
|
client.ReplyToEvent(&m, text)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
err = client.SendText(jid.MustParse(activeMucJid), text)
|
err = client.SendText(jid.MustParse(activeMucJid).Bare(), text)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
dialog.ShowError(err, w)
|
dialog.ShowError(err, w)
|
||||||
}
|
}
|
||||||
@@ -443,6 +554,7 @@ func main() {
|
|||||||
chatTabs[activeMucJid].Messages = append(chatTabs[activeMucJid].Messages, Message{
|
chatTabs[activeMucJid].Messages = append(chatTabs[activeMucJid].Messages, Message{
|
||||||
Author: "You",
|
Author: "You",
|
||||||
Content: text,
|
Content: text,
|
||||||
|
ReplyID: "PICLIENT:UNAVAILABLE",
|
||||||
})
|
})
|
||||||
fyne.Do(func() {
|
fyne.Do(func() {
|
||||||
if scrollDownOnNewMessage {
|
if scrollDownOnNewMessage {
|
||||||
@@ -451,17 +563,23 @@ func main() {
|
|||||||
})
|
})
|
||||||
}
|
}
|
||||||
entry.SetText("")
|
entry.SetText("")
|
||||||
})
|
}
|
||||||
|
|
||||||
|
sendbtn := widget.NewButton("Send", SendCallback)
|
||||||
|
entry.OnSubmitted = func(s string) {
|
||||||
|
SendCallback()
|
||||||
|
// i fucking hate fyne
|
||||||
|
}
|
||||||
|
|
||||||
mit := fyne.NewMenuItem("about pi", func() {
|
mit := fyne.NewMenuItem("about pi", func() {
|
||||||
dialog.ShowInformation("about pi", fmt.Sprintf("the XMPP client from hell\n\npi is an experimental XMPP client\nwritten by Sunglocto in Go.\n\nVersion %s", version), w)
|
dialog.ShowInformation("about pi", fmt.Sprintf("the XMPP client from hell\n\npi is an experimental XMPP client\nwritten by Sunglocto in Go.\n\nVersion %s", version), w)
|
||||||
})
|
})
|
||||||
|
|
||||||
reconnect := fyne.NewMenuItem("reconnect", func() {
|
reconnect := fyne.NewMenuItem("reconnect", func() {
|
||||||
go func(){
|
go func() {
|
||||||
err := client.Connect()
|
err := client.Connect()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
fyne.Do(func(){
|
fyne.Do(func() {
|
||||||
dialog.ShowError(err, w)
|
dialog.ShowError(err, w)
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
@@ -510,85 +628,117 @@ func main() {
|
|||||||
}
|
}
|
||||||
selectedScroller.ScrollToTop()
|
selectedScroller.ScrollToTop()
|
||||||
})
|
})
|
||||||
/*mib := fyne.NewMenuItem("Join a room", func() {
|
|
||||||
nickEntry := widget.NewEntry()
|
w.SetOnDropped(func(p fyne.Position, u []fyne.URI) {
|
||||||
nickEntry.SetText(login.DisplayName)
|
var link string
|
||||||
roomEntry := widget.NewEntry()
|
myUri := u[0] // Only upload a single file
|
||||||
items := []*widget.FormItem{
|
progress := make(chan oasisSdk.UploadProgress)
|
||||||
widget.NewFormItem("Nick", nickEntry),
|
myprogressbar := widget.NewProgressBar()
|
||||||
widget.NewFormItem("MUC address", roomEntry),
|
diag := dialog.NewCustom("Uploading file", "Hide", myprogressbar, w)
|
||||||
|
diag.Show()
|
||||||
|
go func() {
|
||||||
|
client.UploadFile(client.Ctx, myUri.Path(), progress)
|
||||||
|
}()
|
||||||
|
|
||||||
|
for update := range progress {
|
||||||
|
fyne.Do(func() {
|
||||||
|
myprogressbar.Value = float64(update.Percentage) / 100
|
||||||
|
myprogressbar.Refresh()
|
||||||
|
})
|
||||||
|
|
||||||
|
if update.Error != nil {
|
||||||
|
diag.Dismiss()
|
||||||
|
dialog.ShowError(update.Error, w)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
if update.GetURL != "" {
|
||||||
|
link = update.GetURL
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
dialog.ShowForm("join a MUC", "join", "cancel", items, func(b bool) {
|
diag.Dismiss()
|
||||||
if b {
|
a.Clipboard().SetContent(link)
|
||||||
roomJid, err := jid.Parse(roomEntry.Text)
|
dialog.ShowInformation("file successfully uploaded\nURL copied to your clipboard", link, w)
|
||||||
|
|
||||||
|
})
|
||||||
|
|
||||||
|
deb := fyne.NewMenuItem("DEBUG: Attempt to get MAM history from a user", func() {
|
||||||
|
//res, err := history.Fetch(client.Ctx, history.Query{}, jid.MustParse("ringen@muc.isekai.rocks"), client.Session)
|
||||||
|
})
|
||||||
|
mic := fyne.NewMenuItem("upload a file", func() {
|
||||||
|
var link string
|
||||||
|
var toperr error
|
||||||
|
//var topreader fyne.URIReadCloser
|
||||||
|
dialog.ShowFileOpen(func(reader fyne.URIReadCloser, err error) {
|
||||||
|
go func() {
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
dialog.ShowError(err, w)
|
dialog.ShowError(err, w)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
nick := nickEntry.Text
|
if reader == nil {
|
||||||
go func() {
|
return
|
||||||
// We probably don't need to handle the error here, if it fails the user will know
|
}
|
||||||
_, err := client.MucClient.Join(client.Ctx, roomJid, client.Session, nil)
|
bytes, toperr = io.ReadAll(reader)
|
||||||
if err != nil {
|
//topreader = reader
|
||||||
panic(err)
|
|
||||||
}
|
|
||||||
}()
|
|
||||||
addChatTab(true, roomJid, nick)
|
|
||||||
}
|
|
||||||
}, w)
|
|
||||||
})*/
|
|
||||||
|
|
||||||
mic := fyne.NewMenuItem("upload a file", func() {
|
if toperr != nil {
|
||||||
var link string
|
dialog.ShowError(toperr, w)
|
||||||
var bytes []byte
|
|
||||||
var toperr error
|
|
||||||
var topreader fyne.URIReadCloser
|
|
||||||
dialog.ShowFileOpen(func(reader fyne.URIReadCloser, err error) {
|
|
||||||
if err != nil {
|
|
||||||
dialog.ShowError(err, w)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
if reader == nil {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
bytes, toperr = io.ReadAll(reader)
|
|
||||||
topreader = reader
|
|
||||||
|
|
||||||
if toperr != nil {
|
|
||||||
dialog.ShowError(toperr, w)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
progress := make(chan oasisSdk.UploadProgress)
|
|
||||||
myprogressbar := widget.NewProgressBar()
|
|
||||||
dialog.ShowCustom("Uploading file", "Hide", myprogressbar, w)
|
|
||||||
go func() {
|
|
||||||
|
|
||||||
client.UploadFileFromBytes(client.Ctx, topreader.URI().Name(), bytes, progress)
|
|
||||||
}()
|
|
||||||
for update := range progress {
|
|
||||||
myprogressbar.Value = float64(update.Percentage)
|
|
||||||
myprogressbar.Refresh()
|
|
||||||
|
|
||||||
if update.Error != nil {
|
|
||||||
dialog.ShowError(update.Error, w)
|
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
if update.GetURL != "" {
|
progress := make(chan oasisSdk.UploadProgress)
|
||||||
link = update.GetURL
|
myprogressbar := widget.NewProgressBar()
|
||||||
}
|
diag := dialog.NewCustom("Uploading file", "Hide", myprogressbar, w)
|
||||||
}
|
diag.Show()
|
||||||
|
go func() {
|
||||||
|
client.UploadFile(client.Ctx, reader.URI().Path(), progress)
|
||||||
|
}()
|
||||||
|
|
||||||
a.Clipboard().SetContent(link)
|
for update := range progress {
|
||||||
dialog.ShowInformation("file successfully uploaded\nURL copied to your clipboard", link, w)
|
fyne.Do(func() {
|
||||||
|
myprogressbar.Value = float64(update.Percentage) / 100
|
||||||
|
myprogressbar.Refresh()
|
||||||
|
})
|
||||||
|
|
||||||
|
if update.Error != nil {
|
||||||
|
diag.Dismiss()
|
||||||
|
dialog.ShowError(update.Error, w)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
if update.GetURL != "" {
|
||||||
|
link = update.GetURL
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
diag.Dismiss()
|
||||||
|
a.Clipboard().SetContent(link)
|
||||||
|
dialog.ShowInformation("file successfully uploaded\nURL copied to your clipboard", link, w)
|
||||||
|
}()
|
||||||
|
|
||||||
}, w)
|
}, w)
|
||||||
})
|
})
|
||||||
|
|
||||||
menu_help := fyne.NewMenu("π", mit, reconnect)
|
servDisc := fyne.NewMenuItem("Service discovery", func() {
|
||||||
menu_changeroom := fyne.NewMenu("β", mic)
|
|
||||||
|
myBox := container.NewVBox()
|
||||||
|
info, err := disco.GetInfo(client.Ctx, "", jid.MustParse("ringen@muc.isekai.rocks"), client.Session)
|
||||||
|
if err != nil {
|
||||||
|
dialog.ShowError(err, w)
|
||||||
|
}
|
||||||
|
m := info.Features
|
||||||
|
for _, v := range m {
|
||||||
|
myBox.Objects = append(myBox.Objects, widget.NewLabel(v.Var))
|
||||||
|
myBox.Refresh()
|
||||||
|
}
|
||||||
|
|
||||||
|
dialog.ShowCustom("things", "cancel", myBox, w)
|
||||||
|
})
|
||||||
|
|
||||||
|
menu_help := fyne.NewMenu("π", mit, reconnect, deb)
|
||||||
|
menu_changeroom := fyne.NewMenu("β", mic, servDisc)
|
||||||
menu_configureview := fyne.NewMenu("γ", mia, mis, jtt, jtb)
|
menu_configureview := fyne.NewMenu("γ", mia, mis, jtt, jtb)
|
||||||
bit := fyne.NewMenuItem("mark selected message as read", func() {
|
bit := fyne.NewMenuItem("mark selected message as read", func() {
|
||||||
selectedScroller, ok := tabs.Selected().Content.(*widget.List)
|
selectedScroller, ok := tabs.Selected().Content.(*widget.List)
|
||||||
@@ -628,7 +778,7 @@ func main() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
m := chatTabs[activeChatJid].Messages[selectedId].Raw
|
m := chatTabs[activeChatJid].Messages[selectedId].Raw
|
||||||
bytes, err := xml.MarshalIndent(m, "", " ")
|
bytes, err := xml.MarshalIndent(m, "", "\t")
|
||||||
if err != nil {
|
if err != nil {
|
||||||
dialog.ShowError(err, w)
|
dialog.ShowError(err, w)
|
||||||
return
|
return
|
||||||
@@ -644,13 +794,7 @@ func main() {
|
|||||||
|
|
||||||
tabs = container.NewAppTabs(
|
tabs = container.NewAppTabs(
|
||||||
container.NewTabItem("τίποτα", widget.NewLabel(`
|
container.NewTabItem("τίποτα", widget.NewLabel(`
|
||||||
welcome to pi
|
pi
|
||||||
|
|
||||||
you are currently not focused on any rooms.
|
|
||||||
you can add new rooms by editing your pi.json file.
|
|
||||||
in order to change application settings, refer to the tab-menu with the Greek letters.
|
|
||||||
these buttons allow you to configure the application as well as other functions.
|
|
||||||
for more information about the pi project itself, hit the π button.
|
|
||||||
`)),
|
`)),
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -669,6 +813,34 @@ func main() {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
w.SetContent(container.NewVSplit(container.NewVSplit(tabs, container.NewHSplit(entry, sendbtn)), widget.NewLabel("pi")))
|
tabs.OnSelected = func(ti *container.TabItem) {
|
||||||
|
selectedScroller, ok := tabs.Selected().Content.(*widget.List)
|
||||||
|
if !ok {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
var activeChatJid string
|
||||||
|
for jid, tabData := range chatTabs {
|
||||||
|
if tabData.Scroller == selectedScroller {
|
||||||
|
activeChatJid = jid
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
tab := chatTabs[activeChatJid]
|
||||||
|
if tab.isMuc {
|
||||||
|
chatInfo = *container.NewHBox(widget.NewLabel(tab.Muc.Addr().String()))
|
||||||
|
} else {
|
||||||
|
chatInfo = *container.NewHBox(widget.NewLabel(tab.Jid.String()))
|
||||||
|
}
|
||||||
|
|
||||||
|
if tab.isMuc {
|
||||||
|
chatSidebar = *container.NewStack(container.NewVScroll(container.NewVBox(widget.NewRichTextFromMarkdown(fmt.Sprintf("# %s", tab.Jid.String())), widget.NewRichTextFromMarkdown(tab.Muc.Addr().String()))))
|
||||||
|
//chatSidebar.Refresh()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
statBar.SetText("nothing seems to be happening right now...")
|
||||||
|
w.SetContent(container.NewVSplit(container.NewVSplit(container.NewHSplit(tabs, &chatSidebar), container.NewHSplit(entry, sendbtn)), container.NewHSplit(&statBar, &chatInfo)))
|
||||||
w.ShowAndRun()
|
w.ShowAndRun()
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user