zsys.streamlogger.go

// Code generated by streamlogger/generator. DO NOT EDIT.
// source: zsys.pb.go

package zsys

import (
	"context"
	"fmt"

	"github.com/sirupsen/logrus"
	"github.com/ubuntu/zsys/internal/i18n"
	"github.com/ubuntu/zsys/internal/streamlogger"
	"google.golang.org/grpc"
)

/*
  Clients generated code
*/

// ZsysLogClient is a grpc ZsysClient (*zsysClient), augmented by a connexion id in context.
type ZsysLogClient struct {
	ZsysClient
	Ctx context.Context
}

// newZsysClientWithLogs returns a ZsysLogClient, which can send logs at level "level", attached to the given context
func newZsysClientWithLogs(ctx context.Context, cc *grpc.ClientConn, level logrus.Level) *ZsysLogClient {
	return &ZsysLogClient{
		ZsysClient: NewZsysClient(cc),
		Ctx:        streamlogger.NewClientCtx(ctx, level),
	}
}

// Close tear downs the connection under the ZsysLogClient.
func (z *ZsysLogClient) Close() error {
	return z.ZsysClient.(*zsysClient).cc.(*grpc.ClientConn).Close()
}

/*
   Servers
*/

// ZsysLogServer is used to intercept the server and inserting an intermediate log stream.
// This can't be done in interceptor as the creation of each per-function server struct from a grpc.ServerStream
// is only done in the handler() call, which is blocking until the whole handler has ran, once the stream
// has closed.
// It also wraps an idle timeout server, so that the interceptor can stop the idling timeout and reset it after each call.
type ZsysLogServer struct {
	ZsysServerIdleTimeout
}

type ZsysServerIdleTimeout interface {
	ZsysServer
	TrackRequest() func()
}

// registerZsysServerIdleWithLogs wraps the server to an idle timeout server and logged variant intercepting all grpc calls.
func registerZsysServerIdleWithLogs(s *grpc.Server, srv ZsysServerIdleTimeout) {
	RegisterZsysServer(s, &ZsysLogServer{srv})
}

/*
 * Zsys.Version()
 */

// zsysVersionLogStream is a Zsys_VersionServer augmented by its own Context containing the log streamer
type zsysVersionLogStream struct {
	Zsys_VersionServer
	ctx context.Context
}

// Context access the log streamer context
func (s *zsysVersionLogStream) Context() context.Context {
	return s.ctx
}

// Version overrides ZsysServer Version, installing a logger first
func (z *ZsysLogServer) Version(req *Empty, stream Zsys_VersionServer) error {
	// it's ok to panic in the assertion as we expect to have generated above the Write() function.
	ctx, err := streamlogger.AddLogger(stream.(streamlogger.StreamLogger), "Version")
	if err != nil {
		return fmt.Errorf(i18n.G("couldn't attach a logger to request: %w"), err)
	}

	// wrap the context to access the context with logger
	return z.ZsysServerIdleTimeout.Version(req, &zsysVersionLogStream{
		Zsys_VersionServer: stream,
		ctx:                ctx,
	})
}

/*
 * Zsys.CreateUserData()
 */

// zsysCreateUserDataLogStream is a Zsys_CreateUserDataServer augmented by its own Context containing the log streamer
type zsysCreateUserDataLogStream struct {
	Zsys_CreateUserDataServer
	ctx context.Context
}

// Context access the log streamer context
func (s *zsysCreateUserDataLogStream) Context() context.Context {
	return s.ctx
}

// CreateUserData overrides ZsysServer CreateUserData, installing a logger first
func (z *ZsysLogServer) CreateUserData(req *CreateUserDataRequest, stream Zsys_CreateUserDataServer) error {
	// it's ok to panic in the assertion as we expect to have generated above the Write() function.
	ctx, err := streamlogger.AddLogger(stream.(streamlogger.StreamLogger), "CreateUserData")
	if err != nil {
		return fmt.Errorf(i18n.G("couldn't attach a logger to request: %w"), err)
	}

	// wrap the context to access the context with logger
	return z.ZsysServerIdleTimeout.CreateUserData(req, &zsysCreateUserDataLogStream{
		Zsys_CreateUserDataServer: stream,
		ctx:                       ctx,
	})
}

/*
 * Zsys.ChangeHomeOnUserData()
 */

// zsysChangeHomeOnUserDataLogStream is a Zsys_ChangeHomeOnUserDataServer augmented by its own Context containing the log streamer
type zsysChangeHomeOnUserDataLogStream struct {
	Zsys_ChangeHomeOnUserDataServer
	ctx context.Context
}

// Context access the log streamer context
func (s *zsysChangeHomeOnUserDataLogStream) Context() context.Context {
	return s.ctx
}

// ChangeHomeOnUserData overrides ZsysServer ChangeHomeOnUserData, installing a logger first
func (z *ZsysLogServer) ChangeHomeOnUserData(req *ChangeHomeOnUserDataRequest, stream Zsys_ChangeHomeOnUserDataServer) error {
	// it's ok to panic in the assertion as we expect to have generated above the Write() function.
	ctx, err := streamlogger.AddLogger(stream.(streamlogger.StreamLogger), "ChangeHomeOnUserData")
	if err != nil {
		return fmt.Errorf(i18n.G("couldn't attach a logger to request: %w"), err)
	}

	// wrap the context to access the context with logger
	return z.ZsysServerIdleTimeout.ChangeHomeOnUserData(req, &zsysChangeHomeOnUserDataLogStream{
		Zsys_ChangeHomeOnUserDataServer: stream,
		ctx:                             ctx,
	})
}

/*
 * Zsys.DissociateUser()
 */

// zsysDissociateUserLogStream is a Zsys_DissociateUserServer augmented by its own Context containing the log streamer
type zsysDissociateUserLogStream struct {
	Zsys_DissociateUserServer
	ctx context.Context
}

// Context access the log streamer context
func (s *zsysDissociateUserLogStream) Context() context.Context {
	return s.ctx
}

// DissociateUser overrides ZsysServer DissociateUser, installing a logger first
func (z *ZsysLogServer) DissociateUser(req *DissociateUserRequest, stream Zsys_DissociateUserServer) error {
	// it's ok to panic in the assertion as we expect to have generated above the Write() function.
	ctx, err := streamlogger.AddLogger(stream.(streamlogger.StreamLogger), "DissociateUser")
	if err != nil {
		return fmt.Errorf(i18n.G("couldn't attach a logger to request: %w"), err)
	}

	// wrap the context to access the context with logger
	return z.ZsysServerIdleTimeout.DissociateUser(req, &zsysDissociateUserLogStream{
		Zsys_DissociateUserServer: stream,
		ctx:                       ctx,
	})
}

/*
 * Zsys.PrepareBoot()
 */

// zsysPrepareBootLogStream is a Zsys_PrepareBootServer augmented by its own Context containing the log streamer
type zsysPrepareBootLogStream struct {
	Zsys_PrepareBootServer
	ctx context.Context
}

// Context access the log streamer context
func (s *zsysPrepareBootLogStream) Context() context.Context {
	return s.ctx
}

// PrepareBoot overrides ZsysServer PrepareBoot, installing a logger first
func (z *ZsysLogServer) PrepareBoot(req *Empty, stream Zsys_PrepareBootServer) error {
	// it's ok to panic in the assertion as we expect to have generated above the Write() function.
	ctx, err := streamlogger.AddLogger(stream.(streamlogger.StreamLogger), "PrepareBoot")
	if err != nil {
		return fmt.Errorf(i18n.G("couldn't attach a logger to request: %w"), err)
	}

	// wrap the context to access the context with logger
	return z.ZsysServerIdleTimeout.PrepareBoot(req, &zsysPrepareBootLogStream{
		Zsys_PrepareBootServer: stream,
		ctx:                    ctx,
	})
}

/*
 * Zsys.CommitBoot()
 */

// zsysCommitBootLogStream is a Zsys_CommitBootServer augmented by its own Context containing the log streamer
type zsysCommitBootLogStream struct {
	Zsys_CommitBootServer
	ctx context.Context
}

// Context access the log streamer context
func (s *zsysCommitBootLogStream) Context() context.Context {
	return s.ctx
}

// CommitBoot overrides ZsysServer CommitBoot, installing a logger first
func (z *ZsysLogServer) CommitBoot(req *Empty, stream Zsys_CommitBootServer) error {
	// it's ok to panic in the assertion as we expect to have generated above the Write() function.
	ctx, err := streamlogger.AddLogger(stream.(streamlogger.StreamLogger), "CommitBoot")
	if err != nil {
		return fmt.Errorf(i18n.G("couldn't attach a logger to request: %w"), err)
	}

	// wrap the context to access the context with logger
	return z.ZsysServerIdleTimeout.CommitBoot(req, &zsysCommitBootLogStream{
		Zsys_CommitBootServer: stream,
		ctx:                   ctx,
	})
}

/*
 * Zsys.UpdateBootMenu()
 */

// zsysUpdateBootMenuLogStream is a Zsys_UpdateBootMenuServer augmented by its own Context containing the log streamer
type zsysUpdateBootMenuLogStream struct {
	Zsys_UpdateBootMenuServer
	ctx context.Context
}

// Context access the log streamer context
func (s *zsysUpdateBootMenuLogStream) Context() context.Context {
	return s.ctx
}

// UpdateBootMenu overrides ZsysServer UpdateBootMenu, installing a logger first
func (z *ZsysLogServer) UpdateBootMenu(req *UpdateBootMenuRequest, stream Zsys_UpdateBootMenuServer) error {
	// it's ok to panic in the assertion as we expect to have generated above the Write() function.
	ctx, err := streamlogger.AddLogger(stream.(streamlogger.StreamLogger), "UpdateBootMenu")
	if err != nil {
		return fmt.Errorf(i18n.G("couldn't attach a logger to request: %w"), err)
	}

	// wrap the context to access the context with logger
	return z.ZsysServerIdleTimeout.UpdateBootMenu(req, &zsysUpdateBootMenuLogStream{
		Zsys_UpdateBootMenuServer: stream,
		ctx:                       ctx,
	})
}

/*
 * Zsys.UpdateLastUsed()
 */

// zsysUpdateLastUsedLogStream is a Zsys_UpdateLastUsedServer augmented by its own Context containing the log streamer
type zsysUpdateLastUsedLogStream struct {
	Zsys_UpdateLastUsedServer
	ctx context.Context
}

// Context access the log streamer context
func (s *zsysUpdateLastUsedLogStream) Context() context.Context {
	return s.ctx
}

// UpdateLastUsed overrides ZsysServer UpdateLastUsed, installing a logger first
func (z *ZsysLogServer) UpdateLastUsed(req *Empty, stream Zsys_UpdateLastUsedServer) error {
	// it's ok to panic in the assertion as we expect to have generated above the Write() function.
	ctx, err := streamlogger.AddLogger(stream.(streamlogger.StreamLogger), "UpdateLastUsed")
	if err != nil {
		return fmt.Errorf(i18n.G("couldn't attach a logger to request: %w"), err)
	}

	// wrap the context to access the context with logger
	return z.ZsysServerIdleTimeout.UpdateLastUsed(req, &zsysUpdateLastUsedLogStream{
		Zsys_UpdateLastUsedServer: stream,
		ctx:                       ctx,
	})
}

/*
 * Zsys.SaveSystemState()
 */

// zsysSaveSystemStateLogStream is a Zsys_SaveSystemStateServer augmented by its own Context containing the log streamer
type zsysSaveSystemStateLogStream struct {
	Zsys_SaveSystemStateServer
	ctx context.Context
}

// Context access the log streamer context
func (s *zsysSaveSystemStateLogStream) Context() context.Context {
	return s.ctx
}

// SaveSystemState overrides ZsysServer SaveSystemState, installing a logger first
func (z *ZsysLogServer) SaveSystemState(req *SaveSystemStateRequest, stream Zsys_SaveSystemStateServer) error {
	// it's ok to panic in the assertion as we expect to have generated above the Write() function.
	ctx, err := streamlogger.AddLogger(stream.(streamlogger.StreamLogger), "SaveSystemState")
	if err != nil {
		return fmt.Errorf(i18n.G("couldn't attach a logger to request: %w"), err)
	}

	// wrap the context to access the context with logger
	return z.ZsysServerIdleTimeout.SaveSystemState(req, &zsysSaveSystemStateLogStream{
		Zsys_SaveSystemStateServer: stream,
		ctx:                        ctx,
	})
}

/*
 * Zsys.SaveUserState()
 */

// zsysSaveUserStateLogStream is a Zsys_SaveUserStateServer augmented by its own Context containing the log streamer
type zsysSaveUserStateLogStream struct {
	Zsys_SaveUserStateServer
	ctx context.Context
}

// Context access the log streamer context
func (s *zsysSaveUserStateLogStream) Context() context.Context {
	return s.ctx
}

// SaveUserState overrides ZsysServer SaveUserState, installing a logger first
func (z *ZsysLogServer) SaveUserState(req *SaveUserStateRequest, stream Zsys_SaveUserStateServer) error {
	// it's ok to panic in the assertion as we expect to have generated above the Write() function.
	ctx, err := streamlogger.AddLogger(stream.(streamlogger.StreamLogger), "SaveUserState")
	if err != nil {
		return fmt.Errorf(i18n.G("couldn't attach a logger to request: %w"), err)
	}

	// wrap the context to access the context with logger
	return z.ZsysServerIdleTimeout.SaveUserState(req, &zsysSaveUserStateLogStream{
		Zsys_SaveUserStateServer: stream,
		ctx:                      ctx,
	})
}

/*
 * Zsys.RemoveSystemState()
 */

// zsysRemoveSystemStateLogStream is a Zsys_RemoveSystemStateServer augmented by its own Context containing the log streamer
type zsysRemoveSystemStateLogStream struct {
	Zsys_RemoveSystemStateServer
	ctx context.Context
}

// Context access the log streamer context
func (s *zsysRemoveSystemStateLogStream) Context() context.Context {
	return s.ctx
}

// RemoveSystemState overrides ZsysServer RemoveSystemState, installing a logger first
func (z *ZsysLogServer) RemoveSystemState(req *RemoveSystemStateRequest, stream Zsys_RemoveSystemStateServer) error {
	// it's ok to panic in the assertion as we expect to have generated above the Write() function.
	ctx, err := streamlogger.AddLogger(stream.(streamlogger.StreamLogger), "RemoveSystemState")
	if err != nil {
		return fmt.Errorf(i18n.G("couldn't attach a logger to request: %w"), err)
	}

	// wrap the context to access the context with logger
	return z.ZsysServerIdleTimeout.RemoveSystemState(req, &zsysRemoveSystemStateLogStream{
		Zsys_RemoveSystemStateServer: stream,
		ctx:                          ctx,
	})
}

/*
 * Zsys.RemoveUserState()
 */

// zsysRemoveUserStateLogStream is a Zsys_RemoveUserStateServer augmented by its own Context containing the log streamer
type zsysRemoveUserStateLogStream struct {
	Zsys_RemoveUserStateServer
	ctx context.Context
}

// Context access the log streamer context
func (s *zsysRemoveUserStateLogStream) Context() context.Context {
	return s.ctx
}

// RemoveUserState overrides ZsysServer RemoveUserState, installing a logger first
func (z *ZsysLogServer) RemoveUserState(req *RemoveUserStateRequest, stream Zsys_RemoveUserStateServer) error {
	// it's ok to panic in the assertion as we expect to have generated above the Write() function.
	ctx, err := streamlogger.AddLogger(stream.(streamlogger.StreamLogger), "RemoveUserState")
	if err != nil {
		return fmt.Errorf(i18n.G("couldn't attach a logger to request: %w"), err)
	}

	// wrap the context to access the context with logger
	return z.ZsysServerIdleTimeout.RemoveUserState(req, &zsysRemoveUserStateLogStream{
		Zsys_RemoveUserStateServer: stream,
		ctx:                        ctx,
	})
}

/*
 * Zsys.DumpStates()
 */

// zsysDumpStatesLogStream is a Zsys_DumpStatesServer augmented by its own Context containing the log streamer
type zsysDumpStatesLogStream struct {
	Zsys_DumpStatesServer
	ctx context.Context
}

// Context access the log streamer context
func (s *zsysDumpStatesLogStream) Context() context.Context {
	return s.ctx
}

// DumpStates overrides ZsysServer DumpStates, installing a logger first
func (z *ZsysLogServer) DumpStates(req *Empty, stream Zsys_DumpStatesServer) error {
	// it's ok to panic in the assertion as we expect to have generated above the Write() function.
	ctx, err := streamlogger.AddLogger(stream.(streamlogger.StreamLogger), "DumpStates")
	if err != nil {
		return fmt.Errorf(i18n.G("couldn't attach a logger to request: %w"), err)
	}

	// wrap the context to access the context with logger
	return z.ZsysServerIdleTimeout.DumpStates(req, &zsysDumpStatesLogStream{
		Zsys_DumpStatesServer: stream,
		ctx:                   ctx,
	})
}

/*
 * Zsys.DaemonStop()
 */

// zsysDaemonStopLogStream is a Zsys_DaemonStopServer augmented by its own Context containing the log streamer
type zsysDaemonStopLogStream struct {
	Zsys_DaemonStopServer
	ctx context.Context
}

// Context access the log streamer context
func (s *zsysDaemonStopLogStream) Context() context.Context {
	return s.ctx
}

// DaemonStop overrides ZsysServer DaemonStop, installing a logger first
func (z *ZsysLogServer) DaemonStop(req *Empty, stream Zsys_DaemonStopServer) error {
	// it's ok to panic in the assertion as we expect to have generated above the Write() function.
	ctx, err := streamlogger.AddLogger(stream.(streamlogger.StreamLogger), "DaemonStop")
	if err != nil {
		return fmt.Errorf(i18n.G("couldn't attach a logger to request: %w"), err)
	}

	// wrap the context to access the context with logger
	return z.ZsysServerIdleTimeout.DaemonStop(req, &zsysDaemonStopLogStream{
		Zsys_DaemonStopServer: stream,
		ctx:                   ctx,
	})
}

/*
 * Zsys.LoggingLevel()
 */

// zsysLoggingLevelLogStream is a Zsys_LoggingLevelServer augmented by its own Context containing the log streamer
type zsysLoggingLevelLogStream struct {
	Zsys_LoggingLevelServer
	ctx context.Context
}

// Context access the log streamer context
func (s *zsysLoggingLevelLogStream) Context() context.Context {
	return s.ctx
}

// LoggingLevel overrides ZsysServer LoggingLevel, installing a logger first
func (z *ZsysLogServer) LoggingLevel(req *LoggingLevelRequest, stream Zsys_LoggingLevelServer) error {
	// it's ok to panic in the assertion as we expect to have generated above the Write() function.
	ctx, err := streamlogger.AddLogger(stream.(streamlogger.StreamLogger), "LoggingLevel")
	if err != nil {
		return fmt.Errorf(i18n.G("couldn't attach a logger to request: %w"), err)
	}

	// wrap the context to access the context with logger
	return z.ZsysServerIdleTimeout.LoggingLevel(req, &zsysLoggingLevelLogStream{
		Zsys_LoggingLevelServer: stream,
		ctx:                     ctx,
	})
}

/*
 * Zsys.Refresh()
 */

// zsysRefreshLogStream is a Zsys_RefreshServer augmented by its own Context containing the log streamer
type zsysRefreshLogStream struct {
	Zsys_RefreshServer
	ctx context.Context
}

// Context access the log streamer context
func (s *zsysRefreshLogStream) Context() context.Context {
	return s.ctx
}

// Refresh overrides ZsysServer Refresh, installing a logger first
func (z *ZsysLogServer) Refresh(req *Empty, stream Zsys_RefreshServer) error {
	// it's ok to panic in the assertion as we expect to have generated above the Write() function.
	ctx, err := streamlogger.AddLogger(stream.(streamlogger.StreamLogger), "Refresh")
	if err != nil {
		return fmt.Errorf(i18n.G("couldn't attach a logger to request: %w"), err)
	}

	// wrap the context to access the context with logger
	return z.ZsysServerIdleTimeout.Refresh(req, &zsysRefreshLogStream{
		Zsys_RefreshServer: stream,
		ctx:                ctx,
	})
}

/*
 * Zsys.Trace()
 */

// zsysTraceLogStream is a Zsys_TraceServer augmented by its own Context containing the log streamer
type zsysTraceLogStream struct {
	Zsys_TraceServer
	ctx context.Context
}

// Context access the log streamer context
func (s *zsysTraceLogStream) Context() context.Context {
	return s.ctx
}

// Trace overrides ZsysServer Trace, installing a logger first
func (z *ZsysLogServer) Trace(req *TraceRequest, stream Zsys_TraceServer) error {
	// it's ok to panic in the assertion as we expect to have generated above the Write() function.
	ctx, err := streamlogger.AddLogger(stream.(streamlogger.StreamLogger), "Trace")
	if err != nil {
		return fmt.Errorf(i18n.G("couldn't attach a logger to request: %w"), err)
	}

	// wrap the context to access the context with logger
	return z.ZsysServerIdleTimeout.Trace(req, &zsysTraceLogStream{
		Zsys_TraceServer: stream,
		ctx:              ctx,
	})
}

/*
 * Zsys.Status()
 */

// zsysStatusLogStream is a Zsys_StatusServer augmented by its own Context containing the log streamer
type zsysStatusLogStream struct {
	Zsys_StatusServer
	ctx context.Context
}

// Context access the log streamer context
func (s *zsysStatusLogStream) Context() context.Context {
	return s.ctx
}

// Status overrides ZsysServer Status, installing a logger first
func (z *ZsysLogServer) Status(req *Empty, stream Zsys_StatusServer) error {
	// it's ok to panic in the assertion as we expect to have generated above the Write() function.
	ctx, err := streamlogger.AddLogger(stream.(streamlogger.StreamLogger), "Status")
	if err != nil {
		return fmt.Errorf(i18n.G("couldn't attach a logger to request: %w"), err)
	}

	// wrap the context to access the context with logger
	return z.ZsysServerIdleTimeout.Status(req, &zsysStatusLogStream{
		Zsys_StatusServer: stream,
		ctx:               ctx,
	})
}

/*
 * Zsys.Reload()
 */

// zsysReloadLogStream is a Zsys_ReloadServer augmented by its own Context containing the log streamer
type zsysReloadLogStream struct {
	Zsys_ReloadServer
	ctx context.Context
}

// Context access the log streamer context
func (s *zsysReloadLogStream) Context() context.Context {
	return s.ctx
}

// Reload overrides ZsysServer Reload, installing a logger first
func (z *ZsysLogServer) Reload(req *Empty, stream Zsys_ReloadServer) error {
	// it's ok to panic in the assertion as we expect to have generated above the Write() function.
	ctx, err := streamlogger.AddLogger(stream.(streamlogger.StreamLogger), "Reload")
	if err != nil {
		return fmt.Errorf(i18n.G("couldn't attach a logger to request: %w"), err)
	}

	// wrap the context to access the context with logger
	return z.ZsysServerIdleTimeout.Reload(req, &zsysReloadLogStream{
		Zsys_ReloadServer: stream,
		ctx:               ctx,
	})
}

/*
 * Zsys.GC()
 */

// zsysGCLogStream is a Zsys_GCServer augmented by its own Context containing the log streamer
type zsysGCLogStream struct {
	Zsys_GCServer
	ctx context.Context
}

// Context access the log streamer context
func (s *zsysGCLogStream) Context() context.Context {
	return s.ctx
}

// GC overrides ZsysServer GC, installing a logger first
func (z *ZsysLogServer) GC(req *GCRequest, stream Zsys_GCServer) error {
	// it's ok to panic in the assertion as we expect to have generated above the Write() function.
	ctx, err := streamlogger.AddLogger(stream.(streamlogger.StreamLogger), "GC")
	if err != nil {
		return fmt.Errorf(i18n.G("couldn't attach a logger to request: %w"), err)
	}

	// wrap the context to access the context with logger
	return z.ZsysServerIdleTimeout.GC(req, &zsysGCLogStream{
		Zsys_GCServer: stream,
		ctx:           ctx,
	})
}

/*
 * Zsys.MachineShow()
 */

// zsysMachineShowLogStream is a Zsys_MachineShowServer augmented by its own Context containing the log streamer
type zsysMachineShowLogStream struct {
	Zsys_MachineShowServer
	ctx context.Context
}

// Context access the log streamer context
func (s *zsysMachineShowLogStream) Context() context.Context {
	return s.ctx
}

// MachineShow overrides ZsysServer MachineShow, installing a logger first
func (z *ZsysLogServer) MachineShow(req *MachineShowRequest, stream Zsys_MachineShowServer) error {
	// it's ok to panic in the assertion as we expect to have generated above the Write() function.
	ctx, err := streamlogger.AddLogger(stream.(streamlogger.StreamLogger), "MachineShow")
	if err != nil {
		return fmt.Errorf(i18n.G("couldn't attach a logger to request: %w"), err)
	}

	// wrap the context to access the context with logger
	return z.ZsysServerIdleTimeout.MachineShow(req, &zsysMachineShowLogStream{
		Zsys_MachineShowServer: stream,
		ctx:                    ctx,
	})
}

/*
 * Zsys.MachineList()
 */

// zsysMachineListLogStream is a Zsys_MachineListServer augmented by its own Context containing the log streamer
type zsysMachineListLogStream struct {
	Zsys_MachineListServer
	ctx context.Context
}

// Context access the log streamer context
func (s *zsysMachineListLogStream) Context() context.Context {
	return s.ctx
}

// MachineList overrides ZsysServer MachineList, installing a logger first
func (z *ZsysLogServer) MachineList(req *Empty, stream Zsys_MachineListServer) error {
	// it's ok to panic in the assertion as we expect to have generated above the Write() function.
	ctx, err := streamlogger.AddLogger(stream.(streamlogger.StreamLogger), "MachineList")
	if err != nil {
		return fmt.Errorf(i18n.G("couldn't attach a logger to request: %w"), err)
	}

	// wrap the context to access the context with logger
	return z.ZsysServerIdleTimeout.MachineList(req, &zsysMachineListLogStream{
		Zsys_MachineListServer: stream,
		ctx:                    ctx,
	})
}

/*
 * Extend streams to io.Writer
 */

// Write promote zsysVersionServer to an io.Writer
func (s *zsysVersionServer) Write(p []byte) (n int, err error) {
	err = s.Send(
		&VersionResponse{
			Reply: &VersionResponse_Log{Log: string(p)},
		})
	if err != nil {
		return 0, err
	}

	return len(p), nil
}

// Write promote zsysCreateUserDataServer to an io.Writer
func (s *zsysCreateUserDataServer) Write(p []byte) (n int, err error) {
	err = s.Send(
		&LogResponse{
			Log: string(p),
		})
	if err != nil {
		return 0, err
	}

	return len(p), nil
}

// Write promote zsysChangeHomeOnUserDataServer to an io.Writer
func (s *zsysChangeHomeOnUserDataServer) Write(p []byte) (n int, err error) {
	err = s.Send(
		&LogResponse{
			Log: string(p),
		})
	if err != nil {
		return 0, err
	}

	return len(p), nil
}

// Write promote zsysDissociateUserServer to an io.Writer
func (s *zsysDissociateUserServer) Write(p []byte) (n int, err error) {
	err = s.Send(
		&LogResponse{
			Log: string(p),
		})
	if err != nil {
		return 0, err
	}

	return len(p), nil
}

// Write promote zsysPrepareBootServer to an io.Writer
func (s *zsysPrepareBootServer) Write(p []byte) (n int, err error) {
	err = s.Send(
		&PrepareBootResponse{
			Reply: &PrepareBootResponse_Log{Log: string(p)},
		})
	if err != nil {
		return 0, err
	}

	return len(p), nil
}

// Write promote zsysCommitBootServer to an io.Writer
func (s *zsysCommitBootServer) Write(p []byte) (n int, err error) {
	err = s.Send(
		&CommitBootResponse{
			Reply: &CommitBootResponse_Log{Log: string(p)},
		})
	if err != nil {
		return 0, err
	}

	return len(p), nil
}

// Write promote zsysUpdateBootMenuServer to an io.Writer
func (s *zsysUpdateBootMenuServer) Write(p []byte) (n int, err error) {
	err = s.Send(
		&LogResponse{
			Log: string(p),
		})
	if err != nil {
		return 0, err
	}

	return len(p), nil
}

// Write promote zsysUpdateLastUsedServer to an io.Writer
func (s *zsysUpdateLastUsedServer) Write(p []byte) (n int, err error) {
	err = s.Send(
		&LogResponse{
			Log: string(p),
		})
	if err != nil {
		return 0, err
	}

	return len(p), nil
}

// Write promote zsysSaveSystemStateServer to an io.Writer
func (s *zsysSaveSystemStateServer) Write(p []byte) (n int, err error) {
	err = s.Send(
		&CreateSaveStateResponse{
			Reply: &CreateSaveStateResponse_Log{Log: string(p)},
		})
	if err != nil {
		return 0, err
	}

	return len(p), nil
}

// Write promote zsysSaveUserStateServer to an io.Writer
func (s *zsysSaveUserStateServer) Write(p []byte) (n int, err error) {
	err = s.Send(
		&CreateSaveStateResponse{
			Reply: &CreateSaveStateResponse_Log{Log: string(p)},
		})
	if err != nil {
		return 0, err
	}

	return len(p), nil
}

// Write promote zsysRemoveSystemStateServer to an io.Writer
func (s *zsysRemoveSystemStateServer) Write(p []byte) (n int, err error) {
	err = s.Send(
		&LogResponse{
			Log: string(p),
		})
	if err != nil {
		return 0, err
	}

	return len(p), nil
}

// Write promote zsysRemoveUserStateServer to an io.Writer
func (s *zsysRemoveUserStateServer) Write(p []byte) (n int, err error) {
	err = s.Send(
		&LogResponse{
			Log: string(p),
		})
	if err != nil {
		return 0, err
	}

	return len(p), nil
}

// Write promote zsysDumpStatesServer to an io.Writer
func (s *zsysDumpStatesServer) Write(p []byte) (n int, err error) {
	err = s.Send(
		&DumpStatesResponse{
			Reply: &DumpStatesResponse_Log{Log: string(p)},
		})
	if err != nil {
		return 0, err
	}

	return len(p), nil
}

// Write promote zsysDaemonStopServer to an io.Writer
func (s *zsysDaemonStopServer) Write(p []byte) (n int, err error) {
	err = s.Send(
		&LogResponse{
			Log: string(p),
		})
	if err != nil {
		return 0, err
	}

	return len(p), nil
}

// Write promote zsysLoggingLevelServer to an io.Writer
func (s *zsysLoggingLevelServer) Write(p []byte) (n int, err error) {
	err = s.Send(
		&LogResponse{
			Log: string(p),
		})
	if err != nil {
		return 0, err
	}

	return len(p), nil
}

// Write promote zsysRefreshServer to an io.Writer
func (s *zsysRefreshServer) Write(p []byte) (n int, err error) {
	err = s.Send(
		&LogResponse{
			Log: string(p),
		})
	if err != nil {
		return 0, err
	}

	return len(p), nil
}

// Write promote zsysTraceServer to an io.Writer
func (s *zsysTraceServer) Write(p []byte) (n int, err error) {
	err = s.Send(
		&TraceResponse{
			Reply: &TraceResponse_Log{Log: string(p)},
		})
	if err != nil {
		return 0, err
	}

	return len(p), nil
}

// Write promote zsysStatusServer to an io.Writer
func (s *zsysStatusServer) Write(p []byte) (n int, err error) {
	err = s.Send(
		&LogResponse{
			Log: string(p),
		})
	if err != nil {
		return 0, err
	}

	return len(p), nil
}

// Write promote zsysReloadServer to an io.Writer
func (s *zsysReloadServer) Write(p []byte) (n int, err error) {
	err = s.Send(
		&LogResponse{
			Log: string(p),
		})
	if err != nil {
		return 0, err
	}

	return len(p), nil
}

// Write promote zsysGCServer to an io.Writer
func (s *zsysGCServer) Write(p []byte) (n int, err error) {
	err = s.Send(
		&LogResponse{
			Log: string(p),
		})
	if err != nil {
		return 0, err
	}

	return len(p), nil
}

// Write promote zsysMachineShowServer to an io.Writer
func (s *zsysMachineShowServer) Write(p []byte) (n int, err error) {
	err = s.Send(
		&MachineShowResponse{
			Reply: &MachineShowResponse_Log{Log: string(p)},
		})
	if err != nil {
		return 0, err
	}

	return len(p), nil
}

// Write promote zsysMachineListServer to an io.Writer
func (s *zsysMachineListServer) Write(p []byte) (n int, err error) {
	err = s.Send(
		&MachineListResponse{
			Reply: &MachineListResponse_Log{Log: string(p)},
		})
	if err != nil {
		return 0, err
	}

	return len(p), nil
}