service

Documentation

Overview

* @Author: LinkLeong link@icewhale.org * @Date: 2022-07-26 18:13:22 * @LastEditors: LinkLeong * @LastEditTime: 2022-08-04 20:10:31 * @FilePath: /CasaOS/service/connections.go * @Description: * @Website: https://www.casaos.io * Copyright (c) 2022 by icewhale, All Rights Reserved.

* @Author: LinkLeong link@icewhale.com * @Date: 2021-12-20 14:15:46 * @LastEditors: LinkLeong * @LastEditTime: 2022-07-04 16:18:23 * @FilePath: /CasaOS/service/file.go * @Description: * @Website: https://www.casaos.io * Copyright (c) 2022 by icewhale, All Rights Reserved.

* @Author: LinkLeong link@icewhale.com * @Date: 2021-09-30 18:18:14 * @LastEditors: LinkLeong * @LastEditTime: 2022-06-02 18:00:57 * @FilePath: /CasaOS/service/rely.go * @Description: * @Website: https://www.casaos.io * Copyright (c) 2022 by icewhale, All Rights Reserved.

* @Author: LinkLeong link@icewhale.com * @Date: 2022-07-12 09:48:56 * @LastEditors: LinkLeong * @LastEditTime: 2022-09-02 22:10:05 * @FilePath: /CasaOS/service/service.go * @Description: * @Website: https://www.casaos.io * Copyright (c) 2022 by icewhale, All Rights Reserved.

* @Author: LinkLeong link@icewhale.org * @Date: 2022-07-26 11:21:14 * @LastEditors: LinkLeong * @LastEditTime: 2022-08-18 11:16:25 * @FilePath: /CasaOS/service/shares.go * @Description: * @Website: https://www.casaos.io * Copyright (c) 2022 by icewhale, All Rights Reserved.

Index

• Variables
• func CheckFileStatus()
• func ExecOpFile()
• func FileOperate(k string)
• func GetCPUThermalZone() string
• func GetDeviceAllIP() []string
• func NewReader(ctx context.Context, r io.Reader) io.Reader
• func NewWriter(ctx context.Context, w io.Writer) io.Writer
• func SendMeg()
• type CasaService
  • func NewCasaService() CasaService
• type ConnectionsService
  • func NewConnectionsService(db *gorm.DB) ConnectionsService
• type NotifyServer
  • func NewNotifyService(db *gorm.DB) NotifyServer
• type RelyService
  • func NewRelyService(db *gorm.DB) RelyService
• type Repository
  • func NewService(db *gorm.DB, RuntimePath string) Repository
• type SharesService
  • func NewSharesService(db *gorm.DB) SharesService
• type SystemService
  • func NewSystemService() SystemService

Variables

var (
	NotifyMsg   chan notify.Message
	ClientCount int
)

var (
	WebSocketConns []*websocket.Conn
	SocketRun      bool
)

var Cache *cache.Cache

var FileQueue sync.Map

var OpStrArr []string

Functions

func CheckFileStatus

func CheckFileStatus()

file move or copy and send notify

func ExecOpFile

func ExecOpFile()

func FileOperate

func FileOperate(k string)

func GetCPUThermalZone

func GetCPUThermalZone() string

find thermal_zone of cpu. assertions:

• thermal_zone "type" and "temp" are required fields (https://www.kernel.org/doc/Documentation/ABI/testing/sysfs-class-thermal)

func GetDeviceAllIP

func GetDeviceAllIP() []string

func NewReader

func NewReader(ctx context.Context, r io.Reader) io.Reader

NewReader wraps an io.Reader to handle context cancellation.

Context state is checked BEFORE every Read.

func NewWriter

func NewWriter(ctx context.Context, w io.Writer) io.Writer

func SendMeg

func SendMeg()

Types

type CasaService

type CasaService interface {
	GetCasaosVersion() model.Version
}

func NewCasaService

func NewCasaService() CasaService

type ConnectionsService

type ConnectionsService interface {
	GetConnectionsList() (connections []model2.ConnectionsDBModel)
	GetConnectionByHost(host string) (connections []model2.ConnectionsDBModel)
	GetConnectionByID(id string) (connections model2.ConnectionsDBModel)
	CreateConnection(connection *model2.ConnectionsDBModel)
	DeleteConnection(id string)
	UpdateConnection(connection *model2.ConnectionsDBModel)
	MountSmaba(username, host, directory, port, mountPoint, password string) string
	UnmountSmaba(mountPoint string) string
}

func NewConnectionsService

func NewConnectionsService(db *gorm.DB) ConnectionsService

type NotifyServer

type NotifyServer interface {
	GetLog(id string) model.AppNotify
	AddLog(log model.AppNotify)
	UpdateLog(log model.AppNotify)
	UpdateLogByCustomID(log model.AppNotify)
	DelLog(id string)
	GetList(c int) (list []model.AppNotify)
	MarkRead(id string, state int)
	//	SendText(m model.AppNotify)
	SendUninstallAppBySocket(app notifyCommon.Application)
	SendNetInfoBySocket(netList []model2.IOCountersStat)
	SendCPUInfoBySocket(cpu map[string]interface{})
	SendMemInfoBySocket(mem map[string]interface{})
	SendFileOperateNotify(nowSend bool)
	SendInstallAppBySocket(app notifyCommon.Application)
	SendAllHardwareStatusBySocket(mem map[string]interface{}, cpu map[string]interface{}, netList []model2.IOCountersStat)
	SendStorageBySocket(message notify.StorageMessage)
	SendNotify(path string, message map[string]interface{})
	SettingSystemTempData(message map[string]interface{})
	GetSystemTempMap() map[string]interface{}
}

func NewNotifyService

func NewNotifyService(db *gorm.DB) NotifyServer

type RelyService

type RelyService interface {
	Create(rely model2.RelyDBModel)
	Delete(id string)
	GetInfo(id string) model2.RelyDBModel
}

func NewRelyService

func NewRelyService(db *gorm.DB) RelyService

type Repository

type Repository interface {
	// User() UserService
	Casa() CasaService
	Notify() NotifyServer
	Rely() RelyService
	System() SystemService
	Shares() SharesService
	Connections() ConnectionsService
	Gateway() external.ManagementService
}

var MyService Repository

func NewService

func NewService(db *gorm.DB, RuntimePath string) Repository

type SharesService

type SharesService interface {
	GetSharesList() (shares []model2.SharesDBModel)
	GetSharesByPath(path string) (shares []model2.SharesDBModel)
	GetSharesByName(name string) (shares []model2.SharesDBModel)
	CreateShare(share model2.SharesDBModel)
	DeleteShare(id string)
	UpdateConfigFile()
	InitSambaConfig()
	DeleteShareByPath(path string)
}

func NewSharesService

func NewSharesService(db *gorm.DB) SharesService

type SystemService

type SystemService interface {
	UpdateSystemVersion(version string)
	GetSystemConfigDebug() []string
	GetCasaOSLogs(lineNumber int) string
	UpdateAssist()
	UpSystemPort(port string)
	GetTimeZone() string
	UpAppOrderFile(str, id string)
	GetAppOrderFile(id string) []byte
	GetNet(physics bool) []string
	GetNetInfo() []net.IOCountersStat
	GetCpuCoreNum() int
	GetCpuPercent() float64
	GetMemInfo() map[string]interface{}
	GetCpuInfo() []cpu.InfoStat
	GetDirPath(path string) []model.Path
	GetDirPathOne(path string) (m model.Path)
	GetNetState(name string) string
	GetDiskInfo() *disk.UsageStat
	GetSysInfo() host.InfoStat
	GetDeviceTree() string
	CreateFile(path string) (int, error)
	RenameFile(oldF, newF string) (int, error)
	MkdirAll(path string) (int, error)
	IsServiceRunning(name string) bool
	GetCPUTemperature() int
	GetCPUPower() map[string]string
	GetMacAddress() (string, error)
	SystemReboot() error
	SystemShutdown() error
}

func NewSystemService

func NewSystemService() SystemService