/
migrate.go
76 lines (64 loc) · 1.77 KB
/
migrate.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
package sqldb
import (
"bytes"
"fmt"
"io"
"os"
"path/filepath"
"slices"
"github.com/golang-migrate/migrate/v4/source"
meta "encr.dev/proto/encore/parser/meta/v1"
)
type src struct {
appRoot string
migrationsRelPath string
migrations []*meta.DBMigration
}
func (src *src) Open(url string) (source.Driver, error) {
return nil, fmt.Errorf("driver.Open is not implemented")
}
func (src *src) Close() error {
return nil
}
func (src *src) First() (version uint, err error) {
if len(src.migrations) == 0 {
return 0, os.ErrNotExist
}
return uint(src.migrations[0].Number), nil
}
func (src *src) Prev(version uint) (prevVersion uint, err error) {
idx := src.verIdx(version, -1)
if idx < 0 || idx >= len(src.migrations) {
return 0, os.ErrNotExist
}
return uint(src.migrations[idx].Number), nil
}
func (src *src) Next(version uint) (nextVersion uint, err error) {
idx := src.verIdx(version, +1)
if idx >= len(src.migrations) {
return 0, os.ErrNotExist
}
return uint(src.migrations[idx].Number), nil
}
func (src *src) ReadUp(version uint) (r io.ReadCloser, identifier string, err error) {
idx := src.verIdx(version, 0)
if idx < 0 || idx >= len(src.migrations) {
return nil, "", os.ErrNotExist
}
m := src.migrations[idx]
filepath := filepath.Join(src.appRoot, src.migrationsRelPath, m.Filename)
data, err := os.ReadFile(filepath)
if err != nil {
return nil, "", err
}
return io.NopCloser(bytes.NewReader(data)), m.Description, nil
}
func (src *src) ReadDown(version uint) (r io.ReadCloser, identifier string, err error) {
return nil, "", os.ErrNotExist
}
func (src *src) verIdx(version uint, offset int) int {
idx := slices.IndexFunc(src.migrations, func(m *meta.DBMigration) bool {
return m.Number == uint64(version)
})
return idx + offset
}