Compare commits
4 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 07b0744c78 | |||
| 871b1fb8f4 | |||
| baa058d4a4 | |||
| 363c680530 |
14
Dockerfile
14
Dockerfile
@@ -13,26 +13,14 @@ RUN CGO_ENABLED=0 go build -trimpath -ldflags="-s -w -X main.version=${VERSION}"
|
|||||||
|
|
||||||
FROM alpine:3.21
|
FROM alpine:3.21
|
||||||
|
|
||||||
RUN apk add --no-cache ca-certificates tzdata \
|
RUN apk add --no-cache ca-certificates tzdata
|
||||||
&& addgroup -S mcns \
|
|
||||||
&& adduser -S -G mcns -h /srv/mcns -s /sbin/nologin mcns \
|
|
||||||
&& mkdir -p /srv/mcns && chown mcns:mcns /srv/mcns
|
|
||||||
|
|
||||||
COPY --from=builder /build/mcns /usr/local/bin/mcns
|
COPY --from=builder /build/mcns /usr/local/bin/mcns
|
||||||
|
|
||||||
# /srv/mcns is the single volume mount point.
|
|
||||||
# It must contain:
|
|
||||||
# mcns.toml — configuration file
|
|
||||||
# certs/ — TLS certificate and key
|
|
||||||
# mcns.db — created automatically on first run
|
|
||||||
VOLUME /srv/mcns
|
|
||||||
WORKDIR /srv/mcns
|
WORKDIR /srv/mcns
|
||||||
|
|
||||||
EXPOSE 53/udp 53/tcp
|
EXPOSE 53/udp 53/tcp
|
||||||
EXPOSE 8443
|
EXPOSE 8443
|
||||||
EXPOSE 9443
|
EXPOSE 9443
|
||||||
|
|
||||||
USER mcns
|
|
||||||
|
|
||||||
ENTRYPOINT ["mcns"]
|
ENTRYPOINT ["mcns"]
|
||||||
CMD ["server", "--config", "/srv/mcns/mcns.toml"]
|
CMD ["server", "--config", "/srv/mcns/mcns.toml"]
|
||||||
|
|||||||
11
Makefile
11
Makefile
@@ -1,6 +1,8 @@
|
|||||||
.PHONY: build test vet lint proto proto-lint clean docker all devserver
|
.PHONY: build test vet lint proto proto-lint clean docker push all devserver
|
||||||
|
|
||||||
LDFLAGS := -trimpath -ldflags="-s -w -X main.version=$(shell git describe --tags --always --dirty)"
|
MCR := mcr.svc.mcp.metacircular.net:8443
|
||||||
|
VERSION := $(shell git describe --tags --always --dirty)
|
||||||
|
LDFLAGS := -trimpath -ldflags="-s -w -X main.version=$(VERSION)"
|
||||||
|
|
||||||
mcns:
|
mcns:
|
||||||
CGO_ENABLED=0 go build $(LDFLAGS) -o mcns ./cmd/mcns
|
CGO_ENABLED=0 go build $(LDFLAGS) -o mcns ./cmd/mcns
|
||||||
@@ -30,7 +32,10 @@ clean:
|
|||||||
rm -f mcns
|
rm -f mcns
|
||||||
|
|
||||||
docker:
|
docker:
|
||||||
docker build --build-arg VERSION=$(shell git describe --tags --always --dirty) -t mcns -f Dockerfile .
|
docker build --build-arg VERSION=$(VERSION) -t $(MCR)/mcns:$(VERSION) -f Dockerfile .
|
||||||
|
|
||||||
|
push: docker
|
||||||
|
docker push $(MCR)/mcns:$(VERSION)
|
||||||
|
|
||||||
devserver: mcns
|
devserver: mcns
|
||||||
@mkdir -p srv
|
@mkdir -p srv
|
||||||
|
|||||||
@@ -110,7 +110,7 @@ const file_proto_mcns_v1_admin_proto_rawDesc = "" +
|
|||||||
"\x0eHealthResponse\x12\x16\n" +
|
"\x0eHealthResponse\x12\x16\n" +
|
||||||
"\x06status\x18\x01 \x01(\tR\x06status2I\n" +
|
"\x06status\x18\x01 \x01(\tR\x06status2I\n" +
|
||||||
"\fAdminService\x129\n" +
|
"\fAdminService\x129\n" +
|
||||||
"\x06Health\x12\x16.mcns.v1.HealthRequest\x1a\x17.mcns.v1.HealthResponseB/Z-git.wntrmute.dev/mc/mcns/gen/mcns/v1;mcnsv1b\x06proto3"
|
"\x06Health\x12\x16.mcns.v1.HealthRequest\x1a\x17.mcns.v1.HealthResponseB-Z+git.wntrmute.dev/mc/mcns/gen/mcns/v1;mcnsv1b\x06proto3"
|
||||||
|
|
||||||
var (
|
var (
|
||||||
file_proto_mcns_v1_admin_proto_rawDescOnce sync.Once
|
file_proto_mcns_v1_admin_proto_rawDescOnce sync.Once
|
||||||
|
|||||||
@@ -222,7 +222,7 @@ const file_proto_mcns_v1_auth_proto_rawDesc = "" +
|
|||||||
"\x0eLogoutResponse2\x80\x01\n" +
|
"\x0eLogoutResponse2\x80\x01\n" +
|
||||||
"\vAuthService\x126\n" +
|
"\vAuthService\x126\n" +
|
||||||
"\x05Login\x12\x15.mcns.v1.LoginRequest\x1a\x16.mcns.v1.LoginResponse\x129\n" +
|
"\x05Login\x12\x15.mcns.v1.LoginRequest\x1a\x16.mcns.v1.LoginResponse\x129\n" +
|
||||||
"\x06Logout\x12\x16.mcns.v1.LogoutRequest\x1a\x17.mcns.v1.LogoutResponseB/Z-git.wntrmute.dev/mc/mcns/gen/mcns/v1;mcnsv1b\x06proto3"
|
"\x06Logout\x12\x16.mcns.v1.LogoutRequest\x1a\x17.mcns.v1.LogoutResponseB-Z+git.wntrmute.dev/mc/mcns/gen/mcns/v1;mcnsv1b\x06proto3"
|
||||||
|
|
||||||
var (
|
var (
|
||||||
file_proto_mcns_v1_auth_proto_rawDescOnce sync.Once
|
file_proto_mcns_v1_auth_proto_rawDescOnce sync.Once
|
||||||
|
|||||||
@@ -551,7 +551,7 @@ const file_proto_mcns_v1_record_proto_rawDesc = "" +
|
|||||||
"\fCreateRecord\x12\x1c.mcns.v1.CreateRecordRequest\x1a\x0f.mcns.v1.Record\x127\n" +
|
"\fCreateRecord\x12\x1c.mcns.v1.CreateRecordRequest\x1a\x0f.mcns.v1.Record\x127\n" +
|
||||||
"\tGetRecord\x12\x19.mcns.v1.GetRecordRequest\x1a\x0f.mcns.v1.Record\x12=\n" +
|
"\tGetRecord\x12\x19.mcns.v1.GetRecordRequest\x1a\x0f.mcns.v1.Record\x12=\n" +
|
||||||
"\fUpdateRecord\x12\x1c.mcns.v1.UpdateRecordRequest\x1a\x0f.mcns.v1.Record\x12K\n" +
|
"\fUpdateRecord\x12\x1c.mcns.v1.UpdateRecordRequest\x1a\x0f.mcns.v1.Record\x12K\n" +
|
||||||
"\fDeleteRecord\x12\x1c.mcns.v1.DeleteRecordRequest\x1a\x1d.mcns.v1.DeleteRecordResponseB/Z-git.wntrmute.dev/mc/mcns/gen/mcns/v1;mcnsv1b\x06proto3"
|
"\fDeleteRecord\x12\x1c.mcns.v1.DeleteRecordRequest\x1a\x1d.mcns.v1.DeleteRecordResponseB-Z+git.wntrmute.dev/mc/mcns/gen/mcns/v1;mcnsv1b\x06proto3"
|
||||||
|
|
||||||
var (
|
var (
|
||||||
file_proto_mcns_v1_record_proto_rawDescOnce sync.Once
|
file_proto_mcns_v1_record_proto_rawDescOnce sync.Once
|
||||||
|
|||||||
@@ -595,7 +595,7 @@ const file_proto_mcns_v1_zone_proto_rawDesc = "" +
|
|||||||
"\n" +
|
"\n" +
|
||||||
"UpdateZone\x12\x1a.mcns.v1.UpdateZoneRequest\x1a\r.mcns.v1.Zone\x12E\n" +
|
"UpdateZone\x12\x1a.mcns.v1.UpdateZoneRequest\x1a\r.mcns.v1.Zone\x12E\n" +
|
||||||
"\n" +
|
"\n" +
|
||||||
"DeleteZone\x12\x1a.mcns.v1.DeleteZoneRequest\x1a\x1b.mcns.v1.DeleteZoneResponseB/Z-git.wntrmute.dev/mc/mcns/gen/mcns/v1;mcnsv1b\x06proto3"
|
"DeleteZone\x12\x1a.mcns.v1.DeleteZoneRequest\x1a\x1b.mcns.v1.DeleteZoneResponseB-Z+git.wntrmute.dev/mc/mcns/gen/mcns/v1;mcnsv1b\x06proto3"
|
||||||
|
|
||||||
var (
|
var (
|
||||||
file_proto_mcns_v1_zone_proto_rawDescOnce sync.Once
|
file_proto_mcns_v1_zone_proto_rawDescOnce sync.Once
|
||||||
|
|||||||
@@ -769,6 +769,9 @@ func TestMethodMapCompleteness(t *testing.T) {
|
|||||||
"/mcns.v1.ZoneService/GetZone",
|
"/mcns.v1.ZoneService/GetZone",
|
||||||
"/mcns.v1.RecordService/ListRecords",
|
"/mcns.v1.RecordService/ListRecords",
|
||||||
"/mcns.v1.RecordService/GetRecord",
|
"/mcns.v1.RecordService/GetRecord",
|
||||||
|
"/mcns.v1.RecordService/CreateRecord",
|
||||||
|
"/mcns.v1.RecordService/UpdateRecord",
|
||||||
|
"/mcns.v1.RecordService/DeleteRecord",
|
||||||
}
|
}
|
||||||
for _, method := range expectedAuth {
|
for _, method := range expectedAuth {
|
||||||
if !mm.AuthRequired[method] {
|
if !mm.AuthRequired[method] {
|
||||||
@@ -783,9 +786,6 @@ func TestMethodMapCompleteness(t *testing.T) {
|
|||||||
"/mcns.v1.ZoneService/CreateZone",
|
"/mcns.v1.ZoneService/CreateZone",
|
||||||
"/mcns.v1.ZoneService/UpdateZone",
|
"/mcns.v1.ZoneService/UpdateZone",
|
||||||
"/mcns.v1.ZoneService/DeleteZone",
|
"/mcns.v1.ZoneService/DeleteZone",
|
||||||
"/mcns.v1.RecordService/CreateRecord",
|
|
||||||
"/mcns.v1.RecordService/UpdateRecord",
|
|
||||||
"/mcns.v1.RecordService/DeleteRecord",
|
|
||||||
}
|
}
|
||||||
for _, method := range expectedAdmin {
|
for _, method := range expectedAdmin {
|
||||||
if !mm.AdminRequired[method] {
|
if !mm.AdminRequired[method] {
|
||||||
|
|||||||
@@ -25,11 +25,14 @@ func publicMethods() map[string]bool {
|
|||||||
|
|
||||||
func authRequiredMethods() map[string]bool {
|
func authRequiredMethods() map[string]bool {
|
||||||
return map[string]bool{
|
return map[string]bool{
|
||||||
"/mcns.v1.AuthService/Logout": true,
|
"/mcns.v1.AuthService/Logout": true,
|
||||||
"/mcns.v1.ZoneService/ListZones": true,
|
"/mcns.v1.ZoneService/ListZones": true,
|
||||||
"/mcns.v1.ZoneService/GetZone": true,
|
"/mcns.v1.ZoneService/GetZone": true,
|
||||||
"/mcns.v1.RecordService/ListRecords": true,
|
"/mcns.v1.RecordService/ListRecords": true,
|
||||||
"/mcns.v1.RecordService/GetRecord": true,
|
"/mcns.v1.RecordService/GetRecord": true,
|
||||||
|
"/mcns.v1.RecordService/CreateRecord": true,
|
||||||
|
"/mcns.v1.RecordService/UpdateRecord": true,
|
||||||
|
"/mcns.v1.RecordService/DeleteRecord": true,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -38,8 +41,5 @@ func adminRequiredMethods() map[string]bool {
|
|||||||
"/mcns.v1.ZoneService/CreateZone": true,
|
"/mcns.v1.ZoneService/CreateZone": true,
|
||||||
"/mcns.v1.ZoneService/UpdateZone": true,
|
"/mcns.v1.ZoneService/UpdateZone": true,
|
||||||
"/mcns.v1.ZoneService/DeleteZone": true,
|
"/mcns.v1.ZoneService/DeleteZone": true,
|
||||||
"/mcns.v1.RecordService/CreateRecord": true,
|
|
||||||
"/mcns.v1.RecordService/UpdateRecord": true,
|
|
||||||
"/mcns.v1.RecordService/DeleteRecord": true,
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -10,10 +10,36 @@ import (
|
|||||||
"google.golang.org/grpc/status"
|
"google.golang.org/grpc/status"
|
||||||
"google.golang.org/protobuf/types/known/timestamppb"
|
"google.golang.org/protobuf/types/known/timestamppb"
|
||||||
|
|
||||||
|
mcdslauth "git.wntrmute.dev/mc/mcdsl/auth"
|
||||||
|
mcdslgrpc "git.wntrmute.dev/mc/mcdsl/grpcserver"
|
||||||
|
|
||||||
pb "git.wntrmute.dev/mc/mcns/gen/mcns/v1"
|
pb "git.wntrmute.dev/mc/mcns/gen/mcns/v1"
|
||||||
"git.wntrmute.dev/mc/mcns/internal/db"
|
"git.wntrmute.dev/mc/mcns/internal/db"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
// authorizeRecordMutation checks whether the caller may create, update,
|
||||||
|
// or delete a DNS record with the given name. The rules are:
|
||||||
|
//
|
||||||
|
// - admin role: always allowed
|
||||||
|
// - system account "mcp-agent": allowed for any record name
|
||||||
|
// - system account α: allowed only when recordName == α
|
||||||
|
// - all others: denied
|
||||||
|
func authorizeRecordMutation(info *mcdslauth.TokenInfo, recordName string) bool {
|
||||||
|
if info == nil {
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
if info.IsAdmin {
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
if info.AccountType != "system" {
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
if info.Username == "mcp-agent" {
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
return recordName == info.Username
|
||||||
|
}
|
||||||
|
|
||||||
type recordService struct {
|
type recordService struct {
|
||||||
pb.UnimplementedRecordServiceServer
|
pb.UnimplementedRecordServiceServer
|
||||||
db *db.DB
|
db *db.DB
|
||||||
@@ -55,7 +81,7 @@ func (s *recordService) GetRecord(_ context.Context, req *pb.GetRecordRequest) (
|
|||||||
return s.recordToProto(*record), nil
|
return s.recordToProto(*record), nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *recordService) CreateRecord(_ context.Context, req *pb.CreateRecordRequest) (*pb.Record, error) {
|
func (s *recordService) CreateRecord(ctx context.Context, req *pb.CreateRecordRequest) (*pb.Record, error) {
|
||||||
if req.Zone == "" {
|
if req.Zone == "" {
|
||||||
return nil, status.Error(codes.InvalidArgument, "zone is required")
|
return nil, status.Error(codes.InvalidArgument, "zone is required")
|
||||||
}
|
}
|
||||||
@@ -69,6 +95,10 @@ func (s *recordService) CreateRecord(_ context.Context, req *pb.CreateRecordRequ
|
|||||||
return nil, status.Error(codes.InvalidArgument, "value is required")
|
return nil, status.Error(codes.InvalidArgument, "value is required")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if !authorizeRecordMutation(mcdslgrpc.TokenInfoFromContext(ctx), req.Name) {
|
||||||
|
return nil, status.Error(codes.PermissionDenied, "not authorized for record name")
|
||||||
|
}
|
||||||
|
|
||||||
record, err := s.db.CreateRecord(req.Zone, req.Name, req.Type, req.Value, int(req.Ttl))
|
record, err := s.db.CreateRecord(req.Zone, req.Name, req.Type, req.Value, int(req.Ttl))
|
||||||
if errors.Is(err, db.ErrNotFound) {
|
if errors.Is(err, db.ErrNotFound) {
|
||||||
return nil, status.Error(codes.NotFound, "zone not found")
|
return nil, status.Error(codes.NotFound, "zone not found")
|
||||||
@@ -82,7 +112,7 @@ func (s *recordService) CreateRecord(_ context.Context, req *pb.CreateRecordRequ
|
|||||||
return s.recordToProto(*record), nil
|
return s.recordToProto(*record), nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *recordService) UpdateRecord(_ context.Context, req *pb.UpdateRecordRequest) (*pb.Record, error) {
|
func (s *recordService) UpdateRecord(ctx context.Context, req *pb.UpdateRecordRequest) (*pb.Record, error) {
|
||||||
if req.Id <= 0 {
|
if req.Id <= 0 {
|
||||||
return nil, status.Error(codes.InvalidArgument, "id must be positive")
|
return nil, status.Error(codes.InvalidArgument, "id must be positive")
|
||||||
}
|
}
|
||||||
@@ -96,6 +126,15 @@ func (s *recordService) UpdateRecord(_ context.Context, req *pb.UpdateRecordRequ
|
|||||||
return nil, status.Error(codes.InvalidArgument, "value is required")
|
return nil, status.Error(codes.InvalidArgument, "value is required")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
info := mcdslgrpc.TokenInfoFromContext(ctx)
|
||||||
|
existing, lookupErr := s.db.GetRecord(req.Id)
|
||||||
|
if lookupErr == nil && !authorizeRecordMutation(info, existing.Name) {
|
||||||
|
return nil, status.Error(codes.PermissionDenied, "not authorized for record name")
|
||||||
|
}
|
||||||
|
if !authorizeRecordMutation(info, req.Name) {
|
||||||
|
return nil, status.Error(codes.PermissionDenied, "not authorized for record name")
|
||||||
|
}
|
||||||
|
|
||||||
record, err := s.db.UpdateRecord(req.Id, req.Name, req.Type, req.Value, int(req.Ttl))
|
record, err := s.db.UpdateRecord(req.Id, req.Name, req.Type, req.Value, int(req.Ttl))
|
||||||
if errors.Is(err, db.ErrNotFound) {
|
if errors.Is(err, db.ErrNotFound) {
|
||||||
return nil, status.Error(codes.NotFound, "record not found")
|
return nil, status.Error(codes.NotFound, "record not found")
|
||||||
@@ -109,11 +148,16 @@ func (s *recordService) UpdateRecord(_ context.Context, req *pb.UpdateRecordRequ
|
|||||||
return s.recordToProto(*record), nil
|
return s.recordToProto(*record), nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *recordService) DeleteRecord(_ context.Context, req *pb.DeleteRecordRequest) (*pb.DeleteRecordResponse, error) {
|
func (s *recordService) DeleteRecord(ctx context.Context, req *pb.DeleteRecordRequest) (*pb.DeleteRecordResponse, error) {
|
||||||
if req.Id <= 0 {
|
if req.Id <= 0 {
|
||||||
return nil, status.Error(codes.InvalidArgument, "id must be positive")
|
return nil, status.Error(codes.InvalidArgument, "id must be positive")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
existing, lookupErr := s.db.GetRecord(req.Id)
|
||||||
|
if lookupErr == nil && !authorizeRecordMutation(mcdslgrpc.TokenInfoFromContext(ctx), existing.Name) {
|
||||||
|
return nil, status.Error(codes.PermissionDenied, "not authorized for record name")
|
||||||
|
}
|
||||||
|
|
||||||
err := s.db.DeleteRecord(req.Id)
|
err := s.db.DeleteRecord(req.Id)
|
||||||
if errors.Is(err, db.ErrNotFound) {
|
if errors.Is(err, db.ErrNotFound) {
|
||||||
return nil, status.Error(codes.NotFound, "record not found")
|
return nil, status.Error(codes.NotFound, "record not found")
|
||||||
|
|||||||
@@ -42,6 +42,7 @@ func createTestZone(t *testing.T, database *db.DB) *db.Zone {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// newChiRequest builds a request with chi URL params injected into the context.
|
// newChiRequest builds a request with chi URL params injected into the context.
|
||||||
|
// An admin TokenInfo is added so that handler-level authorization passes.
|
||||||
func newChiRequest(method, target string, body string, params map[string]string) *http.Request {
|
func newChiRequest(method, target string, body string, params map[string]string) *http.Request {
|
||||||
var r *http.Request
|
var r *http.Request
|
||||||
if body != "" {
|
if body != "" {
|
||||||
@@ -51,14 +52,21 @@ func newChiRequest(method, target string, body string, params map[string]string)
|
|||||||
}
|
}
|
||||||
r.Header.Set("Content-Type", "application/json")
|
r.Header.Set("Content-Type", "application/json")
|
||||||
|
|
||||||
|
ctx := r.Context()
|
||||||
if len(params) > 0 {
|
if len(params) > 0 {
|
||||||
rctx := chi.NewRouteContext()
|
rctx := chi.NewRouteContext()
|
||||||
for k, v := range params {
|
for k, v := range params {
|
||||||
rctx.URLParams.Add(k, v)
|
rctx.URLParams.Add(k, v)
|
||||||
}
|
}
|
||||||
r = r.WithContext(context.WithValue(r.Context(), chi.RouteCtxKey, rctx))
|
ctx = context.WithValue(ctx, chi.RouteCtxKey, rctx)
|
||||||
}
|
}
|
||||||
return r
|
|
||||||
|
// Inject admin TokenInfo for handler-level authorization.
|
||||||
|
ctx = context.WithValue(ctx, tokenInfoKey, &mcdslauth.TokenInfo{
|
||||||
|
Username: "testadmin",
|
||||||
|
IsAdmin: true,
|
||||||
|
})
|
||||||
|
return r.WithContext(ctx)
|
||||||
}
|
}
|
||||||
|
|
||||||
// decodeJSON decodes the response body into v.
|
// decodeJSON decodes the response body into v.
|
||||||
|
|||||||
@@ -48,6 +48,29 @@ func requireAdmin(next http.Handler) http.Handler {
|
|||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// authorizeRecordMutation checks whether the caller may create, update,
|
||||||
|
// or delete a DNS record with the given name. The rules are:
|
||||||
|
//
|
||||||
|
// - admin role: always allowed
|
||||||
|
// - system account "mcp-agent": allowed for any record name
|
||||||
|
// - system account α: allowed only when recordName == α
|
||||||
|
// - all others: denied
|
||||||
|
func authorizeRecordMutation(info *mcdslauth.TokenInfo, recordName string) bool {
|
||||||
|
if info == nil {
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
if info.IsAdmin {
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
if info.AccountType != "system" {
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
if info.Username == "mcp-agent" {
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
return recordName == info.Username
|
||||||
|
}
|
||||||
|
|
||||||
// tokenInfoFromContext extracts the TokenInfo from the request context.
|
// tokenInfoFromContext extracts the TokenInfo from the request context.
|
||||||
func tokenInfoFromContext(ctx context.Context) *mcdslauth.TokenInfo {
|
func tokenInfoFromContext(ctx context.Context) *mcdslauth.TokenInfo {
|
||||||
info, _ := ctx.Value(tokenInfoKey).(*mcdslauth.TokenInfo)
|
info, _ := ctx.Value(tokenInfoKey).(*mcdslauth.TokenInfo)
|
||||||
|
|||||||
@@ -86,6 +86,11 @@ func createRecordHandler(database *db.DB) http.HandlerFunc {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if !authorizeRecordMutation(tokenInfoFromContext(r.Context()), req.Name) {
|
||||||
|
writeError(w, http.StatusForbidden, "not authorized for record name")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
record, err := database.CreateRecord(zoneName, req.Name, req.Type, req.Value, req.TTL)
|
record, err := database.CreateRecord(zoneName, req.Name, req.Type, req.Value, req.TTL)
|
||||||
if errors.Is(err, db.ErrNotFound) {
|
if errors.Is(err, db.ErrNotFound) {
|
||||||
writeError(w, http.StatusNotFound, "zone not found")
|
writeError(w, http.StatusNotFound, "zone not found")
|
||||||
@@ -132,6 +137,18 @@ func updateRecordHandler(database *db.DB) http.HandlerFunc {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Authorize against both old and new record names.
|
||||||
|
info := tokenInfoFromContext(r.Context())
|
||||||
|
existing, lookupErr := database.GetRecord(id)
|
||||||
|
if lookupErr == nil && !authorizeRecordMutation(info, existing.Name) {
|
||||||
|
writeError(w, http.StatusForbidden, "not authorized for record name")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
if !authorizeRecordMutation(info, req.Name) {
|
||||||
|
writeError(w, http.StatusForbidden, "not authorized for record name")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
record, err := database.UpdateRecord(id, req.Name, req.Type, req.Value, req.TTL)
|
record, err := database.UpdateRecord(id, req.Name, req.Type, req.Value, req.TTL)
|
||||||
if errors.Is(err, db.ErrNotFound) {
|
if errors.Is(err, db.ErrNotFound) {
|
||||||
writeError(w, http.StatusNotFound, "record not found")
|
writeError(w, http.StatusNotFound, "record not found")
|
||||||
@@ -159,6 +176,13 @@ func deleteRecordHandler(database *db.DB) http.HandlerFunc {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Look up the record to authorize by name.
|
||||||
|
existing, lookupErr := database.GetRecord(id)
|
||||||
|
if lookupErr == nil && !authorizeRecordMutation(tokenInfoFromContext(r.Context()), existing.Name) {
|
||||||
|
writeError(w, http.StatusForbidden, "not authorized for record name")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
err = database.DeleteRecord(id)
|
err = database.DeleteRecord(id)
|
||||||
if errors.Is(err, db.ErrNotFound) {
|
if errors.Is(err, db.ErrNotFound) {
|
||||||
writeError(w, http.StatusNotFound, "record not found")
|
writeError(w, http.StatusNotFound, "record not found")
|
||||||
|
|||||||
@@ -44,14 +44,14 @@ func NewRouter(deps Deps) *chi.Mux {
|
|||||||
r.With(requireAdmin).Put("/v1/zones/{zone}", updateZoneHandler(deps.DB))
|
r.With(requireAdmin).Put("/v1/zones/{zone}", updateZoneHandler(deps.DB))
|
||||||
r.With(requireAdmin).Delete("/v1/zones/{zone}", deleteZoneHandler(deps.DB))
|
r.With(requireAdmin).Delete("/v1/zones/{zone}", deleteZoneHandler(deps.DB))
|
||||||
|
|
||||||
// Record endpoints — reads for all authenticated users, writes for admin.
|
// Record endpoints — reads for all authenticated users.
|
||||||
r.Get("/v1/zones/{zone}/records", listRecordsHandler(deps.DB))
|
r.Get("/v1/zones/{zone}/records", listRecordsHandler(deps.DB))
|
||||||
r.Get("/v1/zones/{zone}/records/{id}", getRecordHandler(deps.DB))
|
r.Get("/v1/zones/{zone}/records/{id}", getRecordHandler(deps.DB))
|
||||||
|
|
||||||
// Admin-only record mutations.
|
// Record mutations — admin, mcp-agent (any name), or system account (own name).
|
||||||
r.With(requireAdmin).Post("/v1/zones/{zone}/records", createRecordHandler(deps.DB))
|
r.Post("/v1/zones/{zone}/records", createRecordHandler(deps.DB))
|
||||||
r.With(requireAdmin).Put("/v1/zones/{zone}/records/{id}", updateRecordHandler(deps.DB))
|
r.Put("/v1/zones/{zone}/records/{id}", updateRecordHandler(deps.DB))
|
||||||
r.With(requireAdmin).Delete("/v1/zones/{zone}/records/{id}", deleteRecordHandler(deps.DB))
|
r.Delete("/v1/zones/{zone}/records/{id}", deleteRecordHandler(deps.DB))
|
||||||
})
|
})
|
||||||
|
|
||||||
return r
|
return r
|
||||||
|
|||||||
Reference in New Issue
Block a user