mirror of
https://github.com/TronoSfera/backupy-agent.git
synced 2026-05-18 10:03:30 +03:00
8b0c978337
Source ports from the TronoSfera/backupy-cloud monorepo:
- apps/agent/ — Go agent (WSS client, persistent queue, Docker
discovery, 5 DB drivers: PG/MySQL/Mongo/Redis/SQLite,
pre/post hooks, Prometheus metrics)
- apps/backupy-decrypt/ — standalone CLI for client-side decryption
- packages/proto/ — protobuf wire format (generated .pb.go committed
so the repo builds without protoc)
- docs/ — agent spec + wire-protocol contract
Apache-2.0 license. Image published to ghcr.io/tronosfera/backupy-agent
on every v* tag via .github/workflows/release.yml (multi-arch amd64+arm64).
52 lines
1.6 KiB
Go
52 lines
1.6 KiB
Go
package pipeline
|
|
|
|
import (
|
|
"context"
|
|
"testing"
|
|
|
|
"github.com/stretchr/testify/require"
|
|
|
|
backupv1 "github.com/backupy/backupy/packages/proto/gen/go/backupv1"
|
|
)
|
|
|
|
func TestParseMysqldumpVersion(t *testing.T) {
|
|
cases := map[string]string{
|
|
"mysqldump Ver 8.0.36 for Linux on x86_64 (MySQL Community Server - GPL)": "MySQL 8.0.36",
|
|
"mysqldump Ver 10.6.16-MariaDB": "MySQL 10.6.16-MariaDB",
|
|
}
|
|
for in, want := range cases {
|
|
require.Equal(t, want, parseMysqldumpVersion(in), "input %q", in)
|
|
}
|
|
}
|
|
|
|
func TestIsMysqldumpHeader(t *testing.T) {
|
|
require.True(t, IsMysqldumpHeader([]byte("-- MySQL dump 10.13")))
|
|
require.True(t, IsMysqldumpHeader([]byte("-- MariaDB dump 10.5")))
|
|
require.False(t, IsMysqldumpHeader([]byte("DROP TABLE x;")))
|
|
require.False(t, IsMysqldumpHeader(nil))
|
|
}
|
|
|
|
func TestMysqldump_DumpWritesPayload(t *testing.T) {
|
|
payload := []byte("-- MySQL dump\nINSERT INTO …;\n")
|
|
mock := &mockRunner{
|
|
outputResp: map[string][]byte{"--version": []byte("mysqldump Ver 8.0.36 for Linux …")},
|
|
streamResp: payload,
|
|
}
|
|
d := &mysqldump{binary: "mysqldump", runner: mock}
|
|
target := &backupv1.Target{
|
|
Type: backupv1.DbType_MYSQL,
|
|
Connection: &backupv1.ConnectionConfig{
|
|
Host: "h", Port: 3306, Database: "db", Username: "u", PasswordSecretRef: "p",
|
|
},
|
|
}
|
|
var buf testWriter
|
|
info, err := d.Dump(context.Background(), target, &buf)
|
|
require.NoError(t, err)
|
|
require.Equal(t, "MySQL 8.0.36", info.EngineVersion)
|
|
require.Equal(t, payload, buf.Bytes())
|
|
|
|
// Confirm --password=p inline arg is present.
|
|
require.NotEmpty(t, mock.calls)
|
|
streamCall := mock.calls[0]
|
|
require.Contains(t, streamCall.Args, "--password=p")
|
|
}
|