Compare commits
No commits in common. "master" and "v0.0.43" have entirely different histories.
|
@ -3,7 +3,6 @@ go.mod
|
|||
go.sum
|
||||
/files/*
|
||||
/work/*
|
||||
*.mov
|
||||
|
||||
forgeConfig/forgeConfig
|
||||
scanGoSrc/scanGoSrc
|
||||
|
@ -20,4 +19,3 @@ cf-r2/cf-r2
|
|||
cf-r2/download
|
||||
cf-r2/upload
|
||||
wit-utils
|
||||
vncrecord/vncrecord
|
||||
|
|
|
@ -1,12 +0,0 @@
|
|||
testgo: goimports
|
||||
# GO111MODULE=off go run aistudio.go
|
||||
go run -v aistudio.go
|
||||
|
||||
real:
|
||||
GO111MODULE=off go run aistudio.go
|
||||
|
||||
vet:
|
||||
GO111MODULE=off go vet
|
||||
|
||||
goimports:
|
||||
goimports -w *.go
|
|
@ -1,54 +0,0 @@
|
|||
package main
|
||||
|
||||
import (
|
||||
"context"
|
||||
"fmt"
|
||||
"log"
|
||||
"os"
|
||||
|
||||
// "github.com/google/generative-ai-go/genai"
|
||||
"cloud.google.com/go/ai/vertexai/genai"
|
||||
"google.golang.org/api/option"
|
||||
)
|
||||
|
||||
func main() {
|
||||
ctx := context.Background()
|
||||
|
||||
apiKey := os.Getenv("GEMINI_API_KEY")
|
||||
if apiKey == "" {
|
||||
log.Fatal("GEMINI_API_KEY environment variable not set")
|
||||
}
|
||||
|
||||
client, err := genai.NewClient(ctx, option.WithAPIKey(apiKey))
|
||||
if err != nil {
|
||||
log.Fatalf("Failed to create genai client: %v", err)
|
||||
}
|
||||
defer client.Close()
|
||||
|
||||
model := client.GenerativeModel("gemini-2.5-pro-preview-03-25")
|
||||
|
||||
// Set system instruction
|
||||
model.SystemInstruction = &genai.Content{
|
||||
Parts: []genai.Part{
|
||||
genai.Text("This is for working with the GO language files at http://go.wit.com/"),
|
||||
},
|
||||
}
|
||||
|
||||
// Stream content generation
|
||||
iter := model.GenerateContentStream(ctx, genai.Text("what is the current version of forge on the webpage?"))
|
||||
for {
|
||||
resp, err := iter.Next()
|
||||
if err != nil {
|
||||
break
|
||||
}
|
||||
for _, part := range resp.Candidates {
|
||||
if part.Content != nil {
|
||||
for _, p := range part.Content.Parts {
|
||||
if text, ok := p.(genai.Text); ok {
|
||||
fmt.Print(string(text))
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
|
@ -1,24 +0,0 @@
|
|||
VERSION = $(shell git describe --tags)
|
||||
GUIVERSION = $(shell git describe --tags)
|
||||
BUILDTIME = $(shell date +%s)
|
||||
|
||||
all: vet build
|
||||
|
||||
build: goimports
|
||||
GO111MODULE=off go build \
|
||||
-ldflags "-X main.VERSION=${VERSION} -X main.BUILDTIME=${BUILDTIME} -X gui.GUIVERSION=${VERSION}"
|
||||
|
||||
vet:
|
||||
GO111MODULE=off go vet
|
||||
|
||||
goimports:
|
||||
goimports -w *.go
|
||||
# // to globally reset paths:
|
||||
# // gofmt -w -r '"go.wit.com/gui/gadgets" -> "go.wit.com/lib/gadgets"' *.go
|
||||
|
||||
install: goimports
|
||||
GO111MODULE=off go install \
|
||||
-ldflags "-X main.VERSION=${VERSION} -X main.BUILDTIME=${BUILDTIME} -X gui.GUIVERSION=${VERSION}"
|
||||
|
||||
force: build
|
||||
./go-clone-test --force
|
|
@ -1,12 +0,0 @@
|
|||
//go:generate go run doc/generate.go
|
||||
//go:generate go run misc/completion/generate.go
|
||||
|
||||
package main
|
||||
|
||||
import (
|
||||
"github.com/git-bug/git-bug/commands"
|
||||
)
|
||||
|
||||
func main() {
|
||||
commands.Execute()
|
||||
}
|
|
@ -1,53 +0,0 @@
|
|||
package main
|
||||
|
||||
import (
|
||||
"bufio"
|
||||
"fmt"
|
||||
"log"
|
||||
"net"
|
||||
"strings"
|
||||
)
|
||||
|
||||
const RWhoisPort = "4321"
|
||||
|
||||
func handleConnection(conn net.Conn) {
|
||||
defer conn.Close()
|
||||
|
||||
reader := bufio.NewReader(conn)
|
||||
query, err := reader.ReadString('\n')
|
||||
if err != nil {
|
||||
log.Printf("Error reading query: %v", err)
|
||||
return
|
||||
}
|
||||
query = strings.TrimSpace(query)
|
||||
log.Printf("Received query: %s", query)
|
||||
|
||||
// In a real RWhois server, you would parse the query,
|
||||
// look up data, and potentially issue referrals.
|
||||
// For this example, we'll send a simple response.
|
||||
response := fmt.Sprintf("RWhois response for: %s\n", query)
|
||||
_, err = conn.Write([]byte(response))
|
||||
if err != nil {
|
||||
log.Printf("Error writing response: %v", err)
|
||||
return
|
||||
}
|
||||
}
|
||||
|
||||
func main() {
|
||||
listener, err := net.Listen("tcp", ":"+RWhoisPort)
|
||||
if err != nil {
|
||||
log.Fatalf("Error listening: %v", err)
|
||||
}
|
||||
defer listener.Close()
|
||||
|
||||
log.Printf("RWhois server listening on port %s", RWhoisPort)
|
||||
|
||||
for {
|
||||
conn, err := listener.Accept()
|
||||
if err != nil {
|
||||
log.Printf("Error accepting connection: %v", err)
|
||||
continue
|
||||
}
|
||||
go handleConnection(conn)
|
||||
}
|
||||
}
|
|
@ -1 +0,0 @@
|
|||
TOKEN=5292519055:AAGJPrxYs70PoIWEvLcS3oV3XZ2ldko-M4k
|
|
@ -1,5 +0,0 @@
|
|||
run:
|
||||
go run -v -x send_after.go
|
||||
|
||||
test:
|
||||
curl https://api.telegram.org/bot5292519055:AAGJPrxYs70PoIWEvLcS3oV3XZ2ldko-M4k/getMe
|
|
@ -1,37 +0,0 @@
|
|||
package main
|
||||
|
||||
import (
|
||||
"time"
|
||||
"fmt"
|
||||
|
||||
. "github.com/enetx/g"
|
||||
"github.com/enetx/tg/bot"
|
||||
"github.com/enetx/tg/ctx"
|
||||
)
|
||||
|
||||
func main() {
|
||||
fmt.Println("started...")
|
||||
// Read the bot token from the .env file
|
||||
token := NewFile(".env").Read().Ok().Trim().Split("=").Collect().Last().Some()
|
||||
b := bot.New(token).Build().Unwrap()
|
||||
|
||||
// Register a command handler for /start
|
||||
b.Command("start", func(ctx *ctx.Context) error {
|
||||
// Send an immediate message so Telegram considers the update as "handled"
|
||||
ctx.SendMessage("Preparing self-destruct...").Send()
|
||||
|
||||
// Schedule a second message to be sent after 3 seconds,
|
||||
// and automatically delete it 5 seconds after it is sent
|
||||
ctx.SendMessage("This message will self-destruct in 5 seconds.").
|
||||
After(3 * time.Second). // Delay sending by 3 seconds
|
||||
DeleteAfter(5 * time.Second). // Delete 5 seconds after it is sent
|
||||
Send()
|
||||
|
||||
// Delete the original /start message (from the user)
|
||||
// This should be done after responding to avoid Telegram resending the update
|
||||
return ctx.DeleteMessage().Send().Err()
|
||||
})
|
||||
|
||||
// Start polling for updates and drop any pending ones from before startup
|
||||
b.Polling().DropPendingUpdates().Start()
|
||||
}
|
|
@ -1,10 +0,0 @@
|
|||
all: build test
|
||||
|
||||
build:
|
||||
GO111MODULE=off go build
|
||||
|
||||
test:
|
||||
./vncrecord localhost:6910
|
||||
|
||||
clean:
|
||||
rm -f *.mov vncrecord
|
|
@ -1,186 +0,0 @@
|
|||
package main
|
||||
|
||||
import (
|
||||
"context"
|
||||
"log"
|
||||
"net"
|
||||
"os"
|
||||
"os/signal"
|
||||
"runtime"
|
||||
"runtime/pprof"
|
||||
"syscall"
|
||||
"time"
|
||||
vnc "github.com/amitbet/vnc2video"
|
||||
"github.com/amitbet/vnc2video/encoders"
|
||||
"github.com/amitbet/vnc2video/logger"
|
||||
)
|
||||
|
||||
func main() {
|
||||
runtime.GOMAXPROCS(4)
|
||||
framerate := 12
|
||||
runWithProfiler := false
|
||||
|
||||
// Establish TCP connection to VNC server.
|
||||
nc, err := net.DialTimeout("tcp", os.Args[1], 5*time.Second)
|
||||
if err != nil {
|
||||
logger.Fatalf("Error connecting to VNC host. %v", err)
|
||||
}
|
||||
|
||||
logger.Tracef("starting up the client, connecting to: %s", os.Args[1])
|
||||
// Negotiate connection with the server.
|
||||
cchServer := make(chan vnc.ServerMessage)
|
||||
cchClient := make(chan vnc.ClientMessage)
|
||||
errorCh := make(chan error)
|
||||
|
||||
ccfg := &vnc.ClientConfig{
|
||||
SecurityHandlers: []vnc.SecurityHandler{
|
||||
//&vnc.ClientAuthATEN{Username: []byte(os.Args[2]), Password: []byte(os.Args[3])}
|
||||
// &vnc.ClientAuthVNC{Password: []byte("12345")},
|
||||
&vnc.ClientAuthNone{},
|
||||
},
|
||||
DrawCursor: true,
|
||||
PixelFormat: vnc.PixelFormat32bit,
|
||||
ClientMessageCh: cchClient,
|
||||
ServerMessageCh: cchServer,
|
||||
Messages: vnc.DefaultServerMessages,
|
||||
Encodings: []vnc.Encoding{
|
||||
&vnc.RawEncoding{},
|
||||
&vnc.TightEncoding{},
|
||||
&vnc.HextileEncoding{},
|
||||
&vnc.ZRLEEncoding{},
|
||||
&vnc.CopyRectEncoding{},
|
||||
&vnc.CursorPseudoEncoding{},
|
||||
&vnc.CursorPosPseudoEncoding{},
|
||||
&vnc.ZLibEncoding{},
|
||||
&vnc.RREEncoding{},
|
||||
},
|
||||
ErrorCh: errorCh,
|
||||
}
|
||||
|
||||
cc, err := vnc.Connect(context.Background(), nc, ccfg)
|
||||
screenImage := cc.Canvas
|
||||
if err != nil {
|
||||
logger.Fatalf("Error negotiating connection to VNC host. %v", err)
|
||||
}
|
||||
// out, err := os.Create("./output" + strconv.Itoa(counter) + ".jpg")
|
||||
// if err != nil {
|
||||
// fmt.Println(err)p
|
||||
// os.Exit(1)
|
||||
// }
|
||||
//vcodec := &encoders.MJPegImageEncoder{Quality: 60 , Framerate: framerate}
|
||||
//vcodec := &encoders.X264ImageEncoder{FFMpegBinPath: "./ffmpeg", Framerate: framerate}
|
||||
//vcodec := &encoders.HuffYuvImageEncoder{FFMpegBinPath: "./ffmpeg", Framerate: framerate}
|
||||
vcodec := &encoders.QTRLEImageEncoder{FFMpegBinPath: "/usr/bin/ffmpeg", Framerate: framerate}
|
||||
//vcodec := &encoders.VP8ImageEncoder{FFMpegBinPath:"./ffmpeg", Framerate: framerate}
|
||||
//vcodec := &encoders.DV9ImageEncoder{FFMpegBinPath:"./ffmpeg", Framerate: framerate}
|
||||
|
||||
//counter := 0
|
||||
//vcodec.Init("./output" + strconv.Itoa(counter))
|
||||
|
||||
go vcodec.Run("./output.mp4")
|
||||
//windows
|
||||
///go vcodec.Run("/Users/amitbet/Dropbox/go/src/vnc2webm/example/file-reader/ffmpeg", "./output.mp4")
|
||||
|
||||
//go vcodec.Run("C:\\Users\\betzalel\\Dropbox\\go\\src\\vnc2video\\example\\client\\ffmpeg.exe", "output.mp4")
|
||||
//vcodec.Run("./output")
|
||||
|
||||
//screenImage := vnc.NewVncCanvas(int(cc.Width()), int(cc.Height()))
|
||||
|
||||
for _, enc := range ccfg.Encodings {
|
||||
myRenderer, ok := enc.(vnc.Renderer)
|
||||
|
||||
if ok {
|
||||
myRenderer.SetTargetImage(screenImage)
|
||||
}
|
||||
}
|
||||
// var out *os.File
|
||||
|
||||
logger.Tracef("connected to: %s", os.Args[1])
|
||||
defer cc.Close()
|
||||
|
||||
cc.SetEncodings([]vnc.EncodingType{
|
||||
vnc.EncCursorPseudo,
|
||||
vnc.EncPointerPosPseudo,
|
||||
vnc.EncCopyRect,
|
||||
vnc.EncTight,
|
||||
vnc.EncZRLE,
|
||||
//vnc.EncHextile,
|
||||
//vnc.EncZlib,
|
||||
//vnc.EncRRE,
|
||||
})
|
||||
//rect := image.Rect(0, 0, int(cc.Width()), int(cc.Height()))
|
||||
//screenImage := image.NewRGBA64(rect)
|
||||
// Process messages coming in on the ServerMessage channel.
|
||||
|
||||
go func() {
|
||||
for {
|
||||
timeStart := time.Now()
|
||||
|
||||
vcodec.Encode(screenImage.Image)
|
||||
|
||||
timeTarget := timeStart.Add((1000 / time.Duration(framerate)) * time.Millisecond)
|
||||
timeLeft := timeTarget.Sub(time.Now())
|
||||
if timeLeft > 0 {
|
||||
time.Sleep(timeLeft)
|
||||
}
|
||||
}
|
||||
}()
|
||||
|
||||
sigc := make(chan os.Signal, 1)
|
||||
signal.Notify(sigc,
|
||||
syscall.SIGHUP,
|
||||
syscall.SIGINT,
|
||||
syscall.SIGTERM,
|
||||
syscall.SIGQUIT)
|
||||
frameBufferReq := 0
|
||||
timeStart := time.Now()
|
||||
|
||||
if runWithProfiler {
|
||||
profFile := "prof.file"
|
||||
f, err := os.Create(profFile)
|
||||
if err != nil {
|
||||
log.Fatal(err)
|
||||
}
|
||||
pprof.StartCPUProfile(f)
|
||||
defer pprof.StopCPUProfile()
|
||||
}
|
||||
|
||||
for {
|
||||
select {
|
||||
case err := <-errorCh:
|
||||
panic(err)
|
||||
case msg := <-cchClient:
|
||||
logger.Tracef("Received client message type:%v msg:%v\n", msg.Type(), msg)
|
||||
case msg := <-cchServer:
|
||||
//logger.Tracef("Received server message type:%v msg:%v\n", msg.Type(), msg)
|
||||
|
||||
// out, err := os.Create("./output" + strconv.Itoa(counter) + ".jpg")
|
||||
// if err != nil {
|
||||
// fmt.Println(err)
|
||||
// os.Exit(1)
|
||||
// }
|
||||
|
||||
if msg.Type() == vnc.FramebufferUpdateMsgType {
|
||||
secsPassed := time.Now().Sub(timeStart).Seconds()
|
||||
frameBufferReq++
|
||||
reqPerSec := float64(frameBufferReq) / secsPassed
|
||||
//counter++
|
||||
//jpeg.Encode(out, screenImage, nil)
|
||||
///vcodec.Encode(screenImage)
|
||||
logger.Infof("reqs=%d, seconds=%f, Req Per second= %f", frameBufferReq, secsPassed, reqPerSec)
|
||||
|
||||
reqMsg := vnc.FramebufferUpdateRequest{Inc: 1, X: 0, Y: 0, Width: cc.Width(), Height: cc.Height()}
|
||||
//cc.ResetAllEncodings()
|
||||
reqMsg.Write(cc)
|
||||
}
|
||||
case signal := <-sigc:
|
||||
if signal != nil {
|
||||
vcodec.Close()
|
||||
pprof.StopCPUProfile()
|
||||
time.Sleep(2 * time.Second)
|
||||
os.Exit(1)
|
||||
}
|
||||
}
|
||||
}
|
||||
//cc.Wait()
|
||||
}
|
Loading…
Reference in New Issue