File homeassistant-os-agent-1.6.0.obscpio of Package homeassistant-os-agent

Overview Repositories Revisions Requests Users Attributes Meta

File homeassistant-os-agent-1.6.0.obscpio of Package homeassistant-os-agent (Revision 519af55c388f8c77d691f87d882158e7)

Currently displaying revision 519af55c388f8c77d691f87d882158e7 , Show latest

07070100000000000041ED00000000000000000000000264F6FC3800000000000000000000000000000000000000000000002B00000000homeassistant-os-agent-1.6.0/.devcontainer07070100000001000081A400000000000000000000000164F6FC38000003DD000000000000000000000000000000000000003600000000homeassistant-os-agent-1.6.0/.devcontainer/Dockerfile# [Choice] Go version: 1, 1.15, 1.14
ARG VARIANT=1-bookworm
FROM mcr.microsoft.com/vscode/devcontainers/go:${VARIANT}

# [Option] Install Node.js
ARG NODE_VERSION="lts/*"
RUN if [ "${NODE_VERSION}" != "none" ]; then su vscode -c "umask 0002 && . /usr/local/share/nvm/nvm.sh && nvm install ${NODE_VERSION} 2>&1"; fi

# [Optional] Uncomment this section to install additional OS packages.
RUN apt-get update && export DEBIAN_FRONTEND=noninteractive \
    && apt-get -y install --no-install-recommends \
        dbus \
        libglib2.0-bin \
        apparmor-utils \
    && rm -rf /var/lib/apt/lists/*

# [Optional] Uncomment the next line to use go get to install anything else you need
# RUN go get -x github.com/coreos/go-systemd/daemon
# RUN go get -x github.com/fntlnz/mountinfo
# RUN go get -x github.com/godbus/dbus

# [Optional] Uncomment this line to install global node packages.
# RUN su vscode -c "source /usr/local/share/nvm/nvm.sh && npm install -g <your-package-here>" 2>&1
07070100000002000081ED00000000000000000000000164F6FC3800000197000000000000000000000000000000000000003300000000homeassistant-os-agent-1.6.0/.devcontainer/dbus.sh#!/bin/bash
set -ex

function init_dbus() {
    if pgrep dbus-daemon; then
        echo "Dbus is running"
        return 0
    fi

echo "Startup dbus"
    mkdir -p /var/lib/dbus
    cp -f /etc/machine-id /var/lib/dbus/machine-id

# cleanups
    mkdir -p /run/dbus
    rm -f /run/dbus/pid

# run
    dbus-daemon --system --print-address
}

init_dbus
cp contrib/io.hass.conf /etc/dbus-1/system.d/
07070100000003000081A400000000000000000000000164F6FC38000002AD000000000000000000000000000000000000003D00000000homeassistant-os-agent-1.6.0/.devcontainer/devcontainer.json{
	"name": "Go Home Assistant OS Agent",
	"build": {
		"dockerfile": "Dockerfile",
		"args": {
			"VARIANT": "1.19-bullseye",
			"NODE_VERSION": "none"
		}
	},
	"postCreateCommand": "go mod download",
	"runArgs": [ "--cap-add=SYS_PTRACE", "--security-opt", "seccomp=unconfined" ],
	//"mounts" : [ "source=/run/dbus,target=/run/dbus,type=bind" ],
	"settings": { 
		"terminal.integrated.shell.linux": "/bin/bash",
		"go.useGoProxyToCheckForToolUpdates": false,
		"go.useLanguageServer": true,
		"go.gopath": "/go",
		"go.goroot": "/usr/local/go",
		"go.toolsGopath": "/go/bin",
		"go.lintTool":"golangci-lint",
		"go.lintFlags": [
			"--fast"
		]
	},
	"extensions": [
		"golang.Go"
	]
}
07070100000004000041ED00000000000000000000000264F6FC3800000000000000000000000000000000000000000000002500000000homeassistant-os-agent-1.6.0/.github07070100000005000081A400000000000000000000000164F6FC380000011B000000000000000000000000000000000000003400000000homeassistant-os-agent-1.6.0/.github/dependabot.ymlversion: 2
updates:

- package-ecosystem: gomod
  directory: "/"
  schedule:
    interval: daily
    time: "06:00"
  open-pull-requests-limit: 10

- package-ecosystem: "github-actions"
  directory: "/"
  schedule:
    interval: daily
    time: "06:00"
  open-pull-requests-limit: 10
07070100000006000081A400000000000000000000000164F6FC3800000095000000000000000000000000000000000000003900000000homeassistant-os-agent-1.6.0/.github/release-drafter.ymlname-template: '$RESOLVED_VERSION'
tag-template: '$RESOLVED_VERSION'
version-resolver:
  default: minor
template: |
  ## What's Changed
  
  $CHANGES07070100000007000041ED00000000000000000000000264F6FC3800000000000000000000000000000000000000000000002F00000000homeassistant-os-agent-1.6.0/.github/workflows07070100000008000081A400000000000000000000000164F6FC38000003A0000000000000000000000000000000000000003900000000homeassistant-os-agent-1.6.0/.github/workflows/build.ymlname: build

on:
  release:
    types: ["published"]
  pull_request:
    branches: ["main"]

env:
  GOLANG_VERSION: "1.20"

jobs:
  build:
    name: Build OS-Agent
    runs-on: ubuntu-latest
    steps:
      - name: Checkout the repository
        uses: actions/checkout@v4.0.0
        with:
          fetch-depth: 0 # Needed for changelog generation

- name: Setup go ${{ env.GOLANG_VERSION }}
        uses: actions/setup-go@v4
        with:
          go-version: ${{ env.GOLANG_VERSION }}

- name: Run GoReleaser build
        uses: goreleaser/goreleaser-action@v4.4.0
        if: github.event_name == 'pull_request'
        with:
          args: build --snapshot --clean

- name: Run GoReleaser release
        uses: goreleaser/goreleaser-action@v4.4.0
        if: github.event_name == 'release'
        with:
          args: release --clean
        env:
          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
07070100000009000081A400000000000000000000000164F6FC380000012F000000000000000000000000000000000000004100000000homeassistant-os-agent-1.6.0/.github/workflows/golangci-lint.ymlname: golangci-lint
on:
  push:
    branches:
      - main
  pull_request:
jobs:
  golangci:
    name: lint
    runs-on: ubuntu-latest
    steps:
      - uses: actions/checkout@v4.0.0
      - name: golangci-lint
        uses: golangci/golangci-lint-action@v3.7.0
        with:
          version: latest
0707010000000A000081A400000000000000000000000164F6FC3800000138000000000000000000000000000000000000004300000000homeassistant-os-agent-1.6.0/.github/workflows/release-drafter.ymlname: Release Drafter

on:
  push:
    # branches to consider in the event; optional, defaults to all
    branches:
      - main

jobs:
  update_release_draft:
    runs-on: ubuntu-latest
    steps:
      - uses: release-drafter/release-drafter@v5
        env:
          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
0707010000000B000081A400000000000000000000000164F6FC3800000006000000000000000000000000000000000000002800000000homeassistant-os-agent-1.6.0/.gitignoredist/
0707010000000C000081A400000000000000000000000164F6FC3800000056000000000000000000000000000000000000002C00000000homeassistant-os-agent-1.6.0/.golangci.yamllinters:
  presets:
    - bugs
  enable:
    - gosimple
    - ineffassign
    - unused0707010000000D000081A400000000000000000000000164F6FC380000058F000000000000000000000000000000000000002D00000000homeassistant-os-agent-1.6.0/.goreleaser.ymlproject_name: os-agent
before:
  hooks:
    - go mod tidy
    - go generate ./...
builds:
  - env:
      - CGO_ENABLED=0
    binary: os-agent
    ldflags:
      - -s -w
      - -X main.version={{.Version}}
      - -X main.board=Supervised
    goos:
      - linux
    goarch:
      - 386
      - amd64
      - arm
      - arm64
    goarm:
      - 5
      - 6
      - 7

checksum:
  name_template: checksums.txt
  algorithm: sha512

changelog:
  sort: asc

nfpms:
  - maintainer: Home Assistant <hello@home-assistant.io>
    description: Home Assistant OS Agent
    homepage: https://www.home-assistant.io
    license: Apache 2.0
    section: default
    priority: extra
    bindir: /usr/bin
    formats:
      - deb
    dependencies:
      - udisks2
    file_name_template: >-
      {{ .PackageName }}_{{ .Version }}_{{ .Os }}_
      {{- if eq .Arch "amd64" }}x86_64
      {{- else if eq .Arch "386" }}i386
      {{- else if eq .Arch "arm64" }}aarch64
      {{- else }}{{ .Arch }}{{ with .Arm }}v{{ . }}{{ end }}
      {{ with .Mips }}_{{ . }}{{ end }}
      {{ end }}
    contents:
      - src: contrib/haos-agent.service
        dst: /usr/lib/systemd/system/haos-agent.service
      - src: contrib/io.hass.conf
        dst: /etc/dbus-1/system.d/io.hass.conf
    scripts:
      postinstall: contrib/debian/postinstall.sh
      preremove: contrib/debian/preremove.sh
      postremove: contrib/debian/postremove.sh

release:
0707010000000E000081A400000000000000000000000164F6FC3800002C4E000000000000000000000000000000000000002500000000homeassistant-os-agent-1.6.0/LICENSE                                 Apache License
                           Version 2.0, January 2004
                        http://www.apache.org/licenses/

TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION

1. Definitions.

"License" shall mean the terms and conditions for use, reproduction,
      and distribution as defined by Sections 1 through 9 of this document.

"Licensor" shall mean the copyright owner or entity authorized by
      the copyright owner that is granting the License.

"Legal Entity" shall mean the union of the acting entity and all
      other entities that control, are controlled by, or are under common
      control with that entity. For the purposes of this definition,
      "control" means (i) the power, direct or indirect, to cause the
      direction or management of such entity, whether by contract or
      otherwise, or (ii) ownership of fifty percent (50%) or more of the
      outstanding shares, or (iii) beneficial ownership of such entity.

"You" (or "Your") shall mean an individual or Legal Entity
      exercising permissions granted by this License.

"Source" form shall mean the preferred form for making modifications,
      including but not limited to software source code, documentation
      source, and configuration files.

"Object" form shall mean any form resulting from mechanical
      transformation or translation of a Source form, including but
      not limited to compiled object code, generated documentation,
      and conversions to other media types.

"Work" shall mean the work of authorship, whether in Source or
      Object form, made available under the License, as indicated by a
      copyright notice that is included in or attached to the work
      (an example is provided in the Appendix below).

"Derivative Works" shall mean any work, whether in Source or Object
      form, that is based on (or derived from) the Work and for which the
      editorial revisions, annotations, elaborations, or other modifications
      represent, as a whole, an original work of authorship. For the purposes
      of this License, Derivative Works shall not include works that remain
      separable from, or merely link (or bind by name) to the interfaces of,
      the Work and Derivative Works thereof.

"Contribution" shall mean any work of authorship, including
      the original version of the Work and any modifications or additions
      to that Work or Derivative Works thereof, that is intentionally
      submitted to Licensor for inclusion in the Work by the copyright owner
      or by an individual or Legal Entity authorized to submit on behalf of
      the copyright owner. For the purposes of this definition, "submitted"
      means any form of electronic, verbal, or written communication sent
      to the Licensor or its representatives, including but not limited to
      communication on electronic mailing lists, source code control systems,
      and issue tracking systems that are managed by, or on behalf of, the
      Licensor for the purpose of discussing and improving the Work, but
      excluding communication that is conspicuously marked or otherwise
      designated in writing by the copyright owner as "Not a Contribution."

"Contributor" shall mean Licensor and any individual or Legal Entity
      on behalf of whom a Contribution has been received by Licensor and
      subsequently incorporated within the Work.

2. Grant of Copyright License. Subject to the terms and conditions of
      this License, each Contributor hereby grants to You a perpetual,
      worldwide, non-exclusive, no-charge, royalty-free, irrevocable
      copyright license to reproduce, prepare Derivative Works of,
      publicly display, publicly perform, sublicense, and distribute the
      Work and such Derivative Works in Source or Object form.

3. Grant of Patent License. Subject to the terms and conditions of
      this License, each Contributor hereby grants to You a perpetual,
      worldwide, non-exclusive, no-charge, royalty-free, irrevocable
      (except as stated in this section) patent license to make, have made,
      use, offer to sell, sell, import, and otherwise transfer the Work,
      where such license applies only to those patent claims licensable
      by such Contributor that are necessarily infringed by their
      Contribution(s) alone or by combination of their Contribution(s)
      with the Work to which such Contribution(s) was submitted. If You
      institute patent litigation against any entity (including a
      cross-claim or counterclaim in a lawsuit) alleging that the Work
      or a Contribution incorporated within the Work constitutes direct
      or contributory patent infringement, then any patent licenses
      granted to You under this License for that Work shall terminate
      as of the date such litigation is filed.

4. Redistribution. You may reproduce and distribute copies of the
      Work or Derivative Works thereof in any medium, with or without
      modifications, and in Source or Object form, provided that You
      meet the following conditions:

(a) You must give any other recipients of the Work or
          Derivative Works a copy of this License; and

(b) You must cause any modified files to carry prominent notices
          stating that You changed the files; and

(c) You must retain, in the Source form of any Derivative Works
          that You distribute, all copyright, patent, trademark, and
          attribution notices from the Source form of the Work,
          excluding those notices that do not pertain to any part of
          the Derivative Works; and

(d) If the Work includes a "NOTICE" text file as part of its
          distribution, then any Derivative Works that You distribute must
          include a readable copy of the attribution notices contained
          within such NOTICE file, excluding those notices that do not
          pertain to any part of the Derivative Works, in at least one
          of the following places: within a NOTICE text file distributed
          as part of the Derivative Works; within the Source form or
          documentation, if provided along with the Derivative Works; or,
          within a display generated by the Derivative Works, if and
          wherever such third-party notices normally appear. The contents
          of the NOTICE file are for informational purposes only and
          do not modify the License. You may add Your own attribution
          notices within Derivative Works that You distribute, alongside
          or as an addendum to the NOTICE text from the Work, provided
          that such additional attribution notices cannot be construed
          as modifying the License.

You may add Your own copyright statement to Your modifications and
      may provide additional or different license terms and conditions
      for use, reproduction, or distribution of Your modifications, or
      for any such Derivative Works as a whole, provided Your use,
      reproduction, and distribution of the Work otherwise complies with
      the conditions stated in this License.

5. Submission of Contributions. Unless You explicitly state otherwise,
      any Contribution intentionally submitted for inclusion in the Work
      by You to the Licensor shall be under the terms and conditions of
      this License, without any additional terms or conditions.
      Notwithstanding the above, nothing herein shall supersede or modify
      the terms of any separate license agreement you may have executed
      with Licensor regarding such Contributions.

6. Trademarks. This License does not grant permission to use the trade
      names, trademarks, service marks, or product names of the Licensor,
      except as required for reasonable and customary use in describing the
      origin of the Work and reproducing the content of the NOTICE file.

7. Disclaimer of Warranty. Unless required by applicable law or
      agreed to in writing, Licensor provides the Work (and each
      Contributor provides its Contributions) on an "AS IS" BASIS,
      WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
      implied, including, without limitation, any warranties or conditions
      of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
      PARTICULAR PURPOSE. You are solely responsible for determining the
      appropriateness of using or redistributing the Work and assume any
      risks associated with Your exercise of permissions under this License.

8. Limitation of Liability. In no event and under no legal theory,
      whether in tort (including negligence), contract, or otherwise,
      unless required by applicable law (such as deliberate and grossly
      negligent acts) or agreed to in writing, shall any Contributor be
      liable to You for damages, including any direct, indirect, special,
      incidental, or consequential damages of any character arising as a
      result of this License or out of the use or inability to use the
      Work (including but not limited to damages for loss of goodwill,
      work stoppage, computer failure or malfunction, or any and all
      other commercial damages or losses), even if such Contributor
      has been advised of the possibility of such damages.

9. Accepting Warranty or Additional Liability. While redistributing
      the Work or Derivative Works thereof, You may choose to offer,
      and charge a fee for, acceptance of support, warranty, indemnity,
      or other liability obligations and/or rights consistent with this
      License. However, in accepting such obligations, You may act only
      on Your own behalf and on Your sole responsibility, not on behalf
      of any other Contributor, and only if You agree to indemnify,
      defend, and hold each Contributor harmless for any liability
      incurred by, or claims asserted against, such Contributor by reason
      of your accepting any such warranty or additional liability.

END OF TERMS AND CONDITIONS

APPENDIX: How to apply the Apache License to your work.

To apply the Apache License to your work, attach the following
      boilerplate notice, with the fields enclosed by brackets "[]"
      replaced with your own identifying information. (Don't include
      the brackets!)  The text should be enclosed in the appropriate
      comment syntax for the file format. We also recommend that a
      file or class name and description of purpose be included on the
      same "printed page" as the copyright notice for easier
      identification within third-party archives.

Licensed under the Apache License, Version 2.0 (the "License");
   you may not use this file except in compliance with the License.
   You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
   distributed under the License is distributed on an "AS IS" BASIS,
   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
   See the License for the specific language governing permissions and
   limitations under the License.
0707010000000F000081A400000000000000000000000164F6FC38000006EA000000000000000000000000000000000000002700000000homeassistant-os-agent-1.6.0/README.md# Agent for Home Assistant OS

This is the OS Agent for Home Assistant. It is used for Home Assistant
OS and Home Assistant Supervised installation types and it allows the
Home Assistant Supervisor to communicate with the host operating system.

## Installation & Update

### Using the Home Assistant Operating System

The OS Agent is pre-installed with the Home Assistant Operating System.

Updates are part of the Home Assistant Operating System updates, which
the Home Assistant UI will offer to upgrade to when there is a new version
available.

### Using Home Assistant Supervised on Debian

Download the latest Debian package from OS Agent GitHub release page at:

<https://github.com/home-assistant/os-agent/releases/latest>

Next, install (or update) the downloaded Debian package using:

```shell
sudo dpkg -i os-agent_1.0.0_linux_x86_64.deb
```

Note: Replace the `deb` file in the above example with the file you
have downloaded from the releases page.

You can test if the installation was successful by running:

```bash
gdbus introspect --system --dest io.hass.os --object-path /io/hass/os
```

This should **not** return an error. If you get an object introspection
with `interface` etc. OS Agent is working as expected.

You might need to install `libglib2.0-bin` to get the `gdbus` command.

## Uninstall

To remove OS Agent from your system use the Debian packaging system:

```shell
sudo dpkg -r os-agent
```

## Development

### Compile

```shell
go build -ldflags "-X main.version="
```

### Tests

```shell
gdbus introspect --system --dest io.hass.os --object-path /io/hass/os
gdbus call --system --dest io.hass.os --object-path /io/hass/os/Boards/Yellow --method org.freedesktop.DBus.Properties.Set io.hass.os.Boards.Yellow PowerLED "<false>"
```
07070100000010000041ED00000000000000000000000264F6FC3800000000000000000000000000000000000000000000002600000000homeassistant-os-agent-1.6.0/apparmor07070100000011000081A400000000000000000000000164F6FC3800000B1E000000000000000000000000000000000000003200000000homeassistant-os-agent-1.6.0/apparmor/apparmor.gopackage apparmor

import (
	"fmt"
	"os/exec"
	"regexp"

"github.com/godbus/dbus/v5"
	"github.com/godbus/dbus/v5/introspect"
	"github.com/godbus/dbus/v5/prop"

logging "github.com/home-assistant/os-agent/utils/log"
)

const (
	objectPath        = "/io/hass/os/AppArmor"
	ifaceName         = "io.hass.os.AppArmor"
	appArmorParserCmd = "apparmor_parser"
)

type apparmor struct {
	conn  *dbus.Conn
	props *prop.Properties
}

func getAppArmorVersion() string {
	cmd := exec.Command(appArmorParserCmd, "--version")

out, err := cmd.CombinedOutput()
	if err != nil {
		logging.Warning.Print(err)
		return string("")
	}

re := regexp.MustCompile("version ([0-9.]*)")
	found := re.FindSubmatch(out)
	if len(found) < 1 {
		logging.Error.Fatalln("Can't read version from parser!")
	}

return string(found[1])
}

func (d apparmor) LoadProfile(profilePath string, cachePath string) (bool, *dbus.Error) {
	logging.Info.Printf("Load AppArmor profile '%s'.", profilePath)

cmd := exec.Command(appArmorParserCmd, "--replace", "--write-cache", "--cache-loc", cachePath, profilePath)
	out, err := cmd.CombinedOutput()
	if err != nil {
		return false, dbus.MakeFailedError(fmt.Errorf("Can't load profile '%s': %w", profilePath, err))
	}

logging.Info.Printf("Load profile '%s': %s", profilePath, out)
	return true, nil
}

func (d apparmor) UnloadProfile(profilePath string, cachePath string) (bool, *dbus.Error) {
	logging.Info.Printf("Unload AppArmor profile '%s'.", profilePath)

cmd := exec.Command(appArmorParserCmd, "--remove", "--write-cache", "--cache-loc", cachePath, profilePath)

out, err := cmd.CombinedOutput()
	if err != nil {
		return false, dbus.MakeFailedError(fmt.Errorf("Can't unload profile '%s': %w", profilePath, err))
	}

logging.Info.Printf("Unload profile '%s': %s", profilePath, out)
	return true, nil
}

func InitializeDBus(conn *dbus.Conn) {
	d := apparmor{
		conn: conn,
	}

propsSpec := map[string]map[string]*prop.Prop{
		ifaceName: {
			"ParserVersion": {
				Value:    getAppArmorVersion(),
				Writable: false,
				Emit:     prop.EmitInvalidates,
				Callback: nil,
			},
		},
	}

props, err := prop.Export(conn, objectPath, propsSpec)
	if err != nil {
		logging.Critical.Panic(err)
	}
	d.props = props

err = conn.Export(d, objectPath, ifaceName)
	if err != nil {
		logging.Critical.Panic(err)
	}

node := &introspect.Node{
		Name: objectPath,
		Interfaces: []introspect.Interface{
			introspect.IntrospectData,
			prop.IntrospectData,
			{
				Name:       ifaceName,
				Methods:    introspect.Methods(d),
				Properties: props.Introspection(ifaceName),
			},
		},
	}

err = conn.Export(introspect.NewIntrospectable(node), objectPath, "org.freedesktop.DBus.Introspectable")
	if err != nil {
		logging.Critical.Panic(err)
	}

logging.Info.Printf("Exposing object %s with interface %s ...", objectPath, ifaceName)
}
07070100000012000041ED00000000000000000000000264F6FC3800000000000000000000000000000000000000000000002400000000homeassistant-os-agent-1.6.0/boards07070100000013000081A400000000000000000000000164F6FC3800000702000000000000000000000000000000000000002E00000000homeassistant-os-agent-1.6.0/boards/boards.gopackage boards

import (
	"github.com/godbus/dbus/v5"
	"github.com/godbus/dbus/v5/introspect"
	"github.com/godbus/dbus/v5/prop"

"github.com/home-assistant/os-agent/boards/green"
	"github.com/home-assistant/os-agent/boards/supervised"
	"github.com/home-assistant/os-agent/boards/yellow"
	logging "github.com/home-assistant/os-agent/utils/log"
)

const (
	objectPath = "/io/hass/os/Boards"
	ifaceName  = "io.hass.os.Boards"
)

type boards struct {
	conn  *dbus.Conn
	props *prop.Properties
}

func InitializeDBus(conn *dbus.Conn, board string) {
	d := boards{
		conn: conn,
	}

propsSpec := map[string]map[string]*prop.Prop{
		ifaceName: {
			"Board": {
				Value:    board,
				Writable: false,
				Emit:     prop.EmitInvalidates,
				Callback: nil,
			},
		},
	}

props, err := prop.Export(conn, objectPath, propsSpec)
	if err != nil {
		logging.Critical.Panic(err)
	}
	d.props = props

err = conn.Export(d, objectPath, ifaceName)
	if err != nil {
		logging.Critical.Panic(err)
	}

err = conn.Export(introspect.NewIntrospectable(node), objectPath, "org.freedesktop.DBus.Introspectable")
	if err != nil {
		logging.Critical.Panic(err)
	}

logging.Info.Printf("Exposing object %s with interface %s ...", objectPath, ifaceName)

// Initialize the board
	if board == "Yellow" {
		yellow.InitializeDBus(conn)
	} else if board == "Green" {
		green.InitializeDBus(conn)
	} else if board == "Supervised" {
		supervised.InitializeDBus(conn)
	} else {
		logging.Info.Printf("No specific Board features for %s", board)
	}
}
07070100000014000041ED00000000000000000000000264F6FC3800000000000000000000000000000000000000000000002A00000000homeassistant-os-agent-1.6.0/boards/green07070100000015000081A400000000000000000000000164F6FC3800000A84000000000000000000000000000000000000003300000000homeassistant-os-agent-1.6.0/boards/green/green.gopackage green

import (
	"github.com/godbus/dbus/v5"
	"github.com/godbus/dbus/v5/introspect"
	"github.com/godbus/dbus/v5/prop"

"github.com/home-assistant/os-agent/utils/led"
	logging "github.com/home-assistant/os-agent/utils/log"
)

const (
	objectPath = "/io/hass/os/Boards/Green"
	ifaceName  = "io.hass.os.Boards.Green"
)

var (
	ledPower    led.LED = led.LED{Name: "power", DefaultTrigger: "default-on"}
	ledActivity led.LED = led.LED{Name: "activity", DefaultTrigger: "activity"}
	ledUser     led.LED = led.LED{Name: "user", DefaultTrigger: "heartbeat"}
)

type green struct {
	conn  *dbus.Conn
	props *prop.Properties
}

func getTriggerLED(led led.LED) bool {
	value, err := led.GetTrigger()
	if err != nil {
		logging.Error.Print(err)
	}
	return value != "none"
}

func setTriggerLED(led led.LED, c *prop.Change) *dbus.Error {
	logging.Info.Printf("Set Green %s LED to %t", led.Name, c.Value)
	err := led.SetTrigger(c.Value.(bool))
	if err != nil {
		return dbus.MakeFailedError(err)
	}
	return nil
}

func setPowerLED(c *prop.Change) *dbus.Error {
	return setTriggerLED(ledPower, c)
}

func setActivityLED(c *prop.Change) *dbus.Error {
	return setTriggerLED(ledActivity, c)
}

func setUserLED(c *prop.Change) *dbus.Error {
	return setTriggerLED(ledUser, c)
}

func InitializeDBus(conn *dbus.Conn) {
	d := green{
		conn: conn,
	}

// Init base value
	ledPowerValue := getTriggerLED(ledPower)
	ledActivityValue := getTriggerLED(ledActivity)
	ledUserValue := getTriggerLED(ledUser)

propsSpec := map[string]map[string]*prop.Prop{
		ifaceName: {
			"PowerLED": {
				Value:    ledPowerValue,
				Writable: true,
				Emit:     prop.EmitTrue,
				Callback: setPowerLED,
			},
			"ActivityLED": {
				Value:    ledActivityValue,
				Writable: true,
				Emit:     prop.EmitTrue,
				Callback: setActivityLED,
			},
			"UserLED": {
				Value:    ledUserValue,
				Writable: true,
				Emit:     prop.EmitTrue,
				Callback: setUserLED,
			},
		},
	}

props, err := prop.Export(conn, objectPath, propsSpec)
	if err != nil {
		logging.Critical.Panic(err)
	}
	d.props = props

err = conn.Export(d, objectPath, ifaceName)
	if err != nil {
		logging.Critical.Panic(err)
	}

err = conn.Export(introspect.NewIntrospectable(node), objectPath, "org.freedesktop.DBus.Introspectable")
	if err != nil {
		logging.Critical.Panic(err)
	}

logging.Info.Printf("Exposing object %s with interface %s ...", objectPath, ifaceName)
}
07070100000016000041ED00000000000000000000000264F6FC3800000000000000000000000000000000000000000000002F00000000homeassistant-os-agent-1.6.0/boards/supervised07070100000017000081A400000000000000000000000164F6FC38000003D1000000000000000000000000000000000000003D00000000homeassistant-os-agent-1.6.0/boards/supervised/supervised.gopackage supervised

import (
	"github.com/godbus/dbus/v5"
	"github.com/godbus/dbus/v5/introspect"
	"github.com/godbus/dbus/v5/prop"

logging "github.com/home-assistant/os-agent/utils/log"
)

const (
	objectPath = "/io/hass/os/Boards/Supervised"
	ifaceName  = "io.hass.os.Boards.Supervised"
)

type supervised struct {
	conn *dbus.Conn
}

func InitializeDBus(conn *dbus.Conn) {
	d := supervised{
		conn: conn,
	}

err := conn.Export(d, objectPath, ifaceName)
	if err != nil {
		logging.Critical.Panic(err)
	}

node := &introspect.Node{
		Name: objectPath,
		Interfaces: []introspect.Interface{
			introspect.IntrospectData,
			prop.IntrospectData,
			{
				Name:    ifaceName,
				Methods: introspect.Methods(d),
			},
		},
	}

err = conn.Export(introspect.NewIntrospectable(node), objectPath, "org.freedesktop.DBus.Introspectable")
	if err != nil {
		logging.Critical.Panic(err)
	}

logging.Info.Printf("Exposing object %s with interface %s ...", objectPath, ifaceName)
}
07070100000018000041ED00000000000000000000000264F6FC3800000000000000000000000000000000000000000000002B00000000homeassistant-os-agent-1.6.0/boards/yellow07070100000019000081A400000000000000000000000164F6FC3800000DEE000000000000000000000000000000000000003500000000homeassistant-os-agent-1.6.0/boards/yellow/yellow.gopackage yellow

import (
	"github.com/godbus/dbus/v5"
	"github.com/godbus/dbus/v5/introspect"
	"github.com/godbus/dbus/v5/prop"

"github.com/home-assistant/os-agent/utils/bootfile"
	logging "github.com/home-assistant/os-agent/utils/log"
)

const (
	objectPath = "/io/hass/os/Boards/Yellow"
	ifaceName  = "io.hass.os.Boards.Yellow"
	bootConfig = "/mnt/boot/config.txt"
)

var (
	optLEDPower     bool
	optLEDDisk      bool
	optLEDHeartbeat bool
	bootFile        = bootfile.Editor{FilePath: bootConfig, Delimiter: "="}
)

type yellow struct {
	conn  *dbus.Conn
	props *prop.Properties
}

func getStatusLEDPower() bool {
	value, _ := bootFile.ReadOption("dtparam=pwr_led_trigger", "default-on")
	return value != "none"
}

func getStatusLEDDisk() bool {
	value, _ := bootFile.ReadOption("dtparam=act_led_trigger", "activity")
	return value != "none"
}

func getStatusLEDHeartbeat() bool {
	value, _ := bootFile.ReadOption("dtparam=usr_led_trigger", "heartbeat")
	return value != "none"
}

func setStatusLEDPower(c *prop.Change) *dbus.Error {
	logging.Info.Printf("Set Yellow Power LED to %t", c.Value)
	optLEDPower = c.Value.(bool)

var err error
	if c.Value.(bool) {
		err = bootFile.DisableOption("dtparam=pwr_led_trigger")
	} else {
		err = bootFile.SetOption("dtparam=pwr_led_trigger", "none")
	}

if err != nil {
		return dbus.MakeFailedError(err)
	}
	return nil
}

func setStatusLEDDisk(c *prop.Change) *dbus.Error {
	logging.Info.Printf("Set Yellow Disk LED to %t", c.Value)
	optLEDDisk = c.Value.(bool)

var err error
	if c.Value.(bool) {
		err = bootFile.DisableOption("dtparam=act_led_trigger")
	} else {
		err = bootFile.SetOption("dtparam=act_led_trigger", "none")
	}

if err != nil {
		return dbus.MakeFailedError(err)
	}
	return nil
}

func setStatusLEDHeartbeat(c *prop.Change) *dbus.Error {
	logging.Info.Printf("Set Yellow Heartbeat LED to %t", c.Value)
	optLEDHeartbeat = c.Value.(bool)

var err error
	if c.Value.(bool) {
		err = bootFile.DisableOption("dtparam=usr_led_trigger")
	} else {
		err = bootFile.SetOption("dtparam=usr_led_trigger", "none")
	}

if err != nil {
		return dbus.MakeFailedError(err)
	}
	return nil
}

func InitializeDBus(conn *dbus.Conn) {
	d := yellow{
		conn: conn,
	}

// Init base value
	optLEDPower = getStatusLEDPower()
	optLEDDisk = getStatusLEDDisk()
	optLEDHeartbeat = getStatusLEDHeartbeat()

propsSpec := map[string]map[string]*prop.Prop{
		ifaceName: {
			"PowerLED": {
				Value:    optLEDPower,
				Writable: true,
				Emit:     prop.EmitTrue,
				Callback: setStatusLEDPower,
			},
			"DiskLED": {
				Value:    optLEDDisk,
				Writable: true,
				Emit:     prop.EmitTrue,
				Callback: setStatusLEDDisk,
			},
			"HeartbeatLED": {
				Value:    optLEDHeartbeat,
				Writable: true,
				Emit:     prop.EmitTrue,
				Callback: setStatusLEDHeartbeat,
			},
		},
	}

props, err := prop.Export(conn, objectPath, propsSpec)
	if err != nil {
		logging.Critical.Panic(err)
	}
	d.props = props

err = conn.Export(d, objectPath, ifaceName)
	if err != nil {
		logging.Critical.Panic(err)
	}

err = conn.Export(introspect.NewIntrospectable(node), objectPath, "org.freedesktop.DBus.Introspectable")
	if err != nil {
		logging.Critical.Panic(err)
	}

logging.Info.Printf("Exposing object %s with interface %s ...", objectPath, ifaceName)
}
0707010000001A000041ED00000000000000000000000264F6FC3800000000000000000000000000000000000000000000002400000000homeassistant-os-agent-1.6.0/cgroup0707010000001B000081A400000000000000000000000164F6FC3800001074000000000000000000000000000000000000002E00000000homeassistant-os-agent-1.6.0/cgroup/cgroup.gopackage cgroup

import (
	"encoding/json"
	"fmt"
	"os"
	"os/exec"
	"path/filepath"

securejoin "github.com/cyphar/filepath-securejoin"
	"github.com/godbus/dbus/v5"
	"github.com/godbus/dbus/v5/introspect"
	"github.com/godbus/dbus/v5/prop"

logging "github.com/home-assistant/os-agent/utils/log"
)

const (
	objectPath            = "/io/hass/os/CGroup"
	ifaceName             = "io.hass.os.CGroup"
	cgroupFSDockerDevices = "/sys/fs/cgroup/devices/docker"
)

type CGroupVersion int

const (
	CGroupUnknown CGroupVersion = iota
	CGroupV1
	CGroupV2
)

type cgroup struct {
	conn          *dbus.Conn
	cgroupVersion CGroupVersion
}

func (d cgroup) AddDevicesAllowed(containerID string, permission string) (bool, *dbus.Error) {
	if d.cgroupVersion == CGroupV2 {
		permissions := []string{permission}
		resources, err := CreateDeviceUpdateResources(permissions)
		if err != nil {
			error := fmt.Errorf("Error creating device resources for '%s': %w", containerID, err)
			logging.Error.Printf("%s", error)
			return false, dbus.MakeFailedError(error)
		}

cmd := exec.Command("runc", "--root", "/var/run/docker/runtime-runc/moby/", "update", "--resources", "-", containerID)

// Pass resources as OCI LinuxResources JSON object
		stdin, err := cmd.StdinPipe()
		if err != nil {
			error := fmt.Errorf("Error creating stdin pipe for '%s': %w", containerID, err)
			logging.Error.Printf("%s", error)
			return false, dbus.MakeFailedError(error)
		}
		enc := json.NewEncoder(stdin)
		err = enc.Encode(resources)
		if err != nil {
			error := fmt.Errorf("Error encoding JSON for '%s': %w", containerID, err)
			logging.Error.Printf("%s", error)
			return false, dbus.MakeFailedError(error)
		}
		stdin.Close()

stdoutStderr, err := cmd.CombinedOutput()
		if err != nil {
			error := fmt.Errorf("Error calling runc for '%s': %w, output %s", containerID, err, stdoutStderr)
			logging.Error.Printf("%s", error)
			return false, dbus.MakeFailedError(error)
		} else {
			logging.Info.Printf("Successfully called runc for '%s', output %s", containerID, stdoutStderr)
		}

logging.Info.Printf("Permission '%s', granted for Container '%s' via runc", permission, containerID)
		return true, nil
	} else {
		// Make sure path is relative to cgroupFSDockerDevices
		allowedFile, err := securejoin.SecureJoin(cgroupFSDockerDevices, containerID+string(filepath.Separator)+"devices.allow")
		if err != nil {
			return false, dbus.MakeFailedError(fmt.Errorf("Security issues with '%s': %w", containerID, err))
		}

// Check if file/container exists
		_, err = os.Stat(allowedFile)
		if os.IsNotExist(err) {
			return false, dbus.MakeFailedError(fmt.Errorf("Can't find Container '%s' for adjust CGroup devices.", containerID))
		}

// Write permission adjustments
		file, err := os.Create(allowedFile)
		if err != nil {
			return false, dbus.MakeFailedError(fmt.Errorf("Can't open CGroup devices '%s': %w", allowedFile, err))
		}
		defer file.Close()

_, err = file.WriteString(permission + "\n")
		if err != nil {
			return false, dbus.MakeFailedError(fmt.Errorf("Can't write CGroup permission '%s': %w", permission, err))
		}

logging.Info.Printf("Permission '%s', granted for Container '%s' via CGroup devices.allow", permission, containerID)
		return true, nil
	}
}

func InitializeDBus(conn *dbus.Conn) {
	d := cgroup{
		conn:          conn,
		cgroupVersion: CGroupUnknown,
	}

// Check for CGroups v2
	if _, err := os.Stat("/sys/fs/cgroup/cgroup.controllers"); err == nil {
		d.cgroupVersion = CGroupV2
		logging.Info.Printf("Detected CGroups Version 2")
	} else {
		d.cgroupVersion = CGroupV1
		logging.Info.Printf("Detected CGroups Version 1")
	}

err := conn.Export(d, objectPath, ifaceName)
	if err != nil {
		logging.Critical.Panic(err)
	}

node := &introspect.Node{
		Name: objectPath,
		Interfaces: []introspect.Interface{
			introspect.IntrospectData,
			prop.IntrospectData,
			{
				Name:    ifaceName,
				Methods: introspect.Methods(d),
			},
		},
	}

err = conn.Export(introspect.NewIntrospectable(node), objectPath, "org.freedesktop.DBus.Introspectable")
	if err != nil {
		logging.Critical.Panic(err)
	}

logging.Info.Printf("Exposing object %s with interface %s ...", objectPath, ifaceName)
}
0707010000001C000081A400000000000000000000000164F6FC38000006C9000000000000000000000000000000000000002B00000000homeassistant-os-agent-1.6.0/cgroup/oci.gopackage cgroup

import (
	"fmt"
	"regexp"
	"strconv"

"github.com/opencontainers/runtime-spec/specs-go"
)

var deviceCgroupRuleRegex = regexp.MustCompile(`^([acb]) ([0-9]+|\*):([0-9]+|\*) ([rwm]{1,3})$`)

// Lifted from Moby's oci/oci.go
func AppendDevicePermissionsFromCgroupRules(devPermissions []specs.LinuxDeviceCgroup, rules []string) ([]specs.LinuxDeviceCgroup, error) {
	for _, deviceCgroupRule := range rules {
		ss := deviceCgroupRuleRegex.FindAllStringSubmatch(deviceCgroupRule, -1)
		if len(ss) == 0 || len(ss[0]) != 5 {
			return nil, fmt.Errorf("invalid device cgroup rule format: '%s'", deviceCgroupRule)
		}
		matches := ss[0]

dPermissions := specs.LinuxDeviceCgroup{
			Allow:  true,
			Type:   matches[1],
			Access: matches[4],
		}
		if matches[2] == "*" {
			major := int64(-1)
			dPermissions.Major = &major
		} else {
			major, err := strconv.ParseInt(matches[2], 10, 64)
			if err != nil {
				return nil, fmt.Errorf("invalid major value in device cgroup rule format: '%s'", deviceCgroupRule)
			}
			dPermissions.Major = &major
		}
		if matches[3] == "*" {
			minor := int64(-1)
			dPermissions.Minor = &minor
		} else {
			minor, err := strconv.ParseInt(matches[3], 10, 64)
			if err != nil {
				return nil, fmt.Errorf("invalid minor value in device cgroup rule format: '%s'", deviceCgroupRule)
			}
			dPermissions.Minor = &minor
		}
		devPermissions = append(devPermissions, dPermissions)
	}
	return devPermissions, nil
}

func CreateDeviceUpdateResources(rules []string) (*specs.LinuxResources, error) {
	resources := specs.LinuxResources{}

devices, err := AppendDevicePermissionsFromCgroupRules(nil, rules)
	if err != nil {
		return nil, err
	}

resources.Devices = devices

return &resources, nil
}
0707010000001D000041ED00000000000000000000000264F6FC3800000000000000000000000000000000000000000000002500000000homeassistant-os-agent-1.6.0/contrib0707010000001E000041ED00000000000000000000000264F6FC3800000000000000000000000000000000000000000000002C00000000homeassistant-os-agent-1.6.0/contrib/debian0707010000001F000081A400000000000000000000000164F6FC380000005B000000000000000000000000000000000000003B00000000homeassistant-os-agent-1.6.0/contrib/debian/postinstall.sh#!/bin/bash
systemctl daemon-reload
systemctl enable haos-agent
systemctl start haos-agent
07070100000020000081A400000000000000000000000164F6FC3800000024000000000000000000000000000000000000003A00000000homeassistant-os-agent-1.6.0/contrib/debian/postremove.sh#!/bin/bash
systemctl daemon-reload
07070100000021000081A400000000000000000000000164F6FC3800000043000000000000000000000000000000000000003900000000homeassistant-os-agent-1.6.0/contrib/debian/preremove.sh#!/bin/bash
systemctl stop haos-agent
systemctl disable haos-agent
07070100000022000081A400000000000000000000000164F6FC380000014E000000000000000000000000000000000000003800000000homeassistant-os-agent-1.6.0/contrib/haos-agent.service[Unit]
Description=Home Assistant OS Agent
DefaultDependencies=no
Requires=dbus.socket udisks2.service
After=dbus.socket

[Service]
BusName=io.hass.os
Type=notify
Restart=always
RestartSec=5s
Environment="DBUS_SYSTEM_BUS_ADDRESS=unix:path=/run/dbus/system_bus_socket"
ExecStart=/usr/bin/os-agent

[Install]
WantedBy=multi-user.target
07070100000023000081A400000000000000000000000164F6FC38000001F8000000000000000000000000000000000000003200000000homeassistant-os-agent-1.6.0/contrib/io.hass.conf<!DOCTYPE busconfig PUBLIC
          "-//freedesktop//DTD D-BUS Bus Configuration 1.0//EN"
          "http://www.freedesktop.org/standards/dbus/1.0/busconfig.dtd">
<busconfig>
  
  <policy user="root">
    <allow own="io.hass.os"/>
  </policy>
  <policy group="root">
    <allow own="io.hass.os"/>
  </policy>

<policy context="default">
    <allow send_destination="io.hass.os"/>
    <allow receive_sender="io.hass.os"/>
  </policy>
</busconfig>
07070100000024000041ED00000000000000000000000264F6FC3800000000000000000000000000000000000000000000002600000000homeassistant-os-agent-1.6.0/datadisk07070100000025000081A400000000000000000000000164F6FC3800000DB7000000000000000000000000000000000000003200000000homeassistant-os-agent-1.6.0/datadisk/datadisk.gopackage datadisk

import (
	"errors"
	"fmt"
	"os"

"github.com/fntlnz/mountinfo"
	"github.com/godbus/dbus/v5"
	"github.com/godbus/dbus/v5/introspect"
	"github.com/godbus/dbus/v5/prop"

"github.com/home-assistant/os-agent/udisks2"
	logging "github.com/home-assistant/os-agent/utils/log"
)

const (
	dataMount              = "/mnt/data"
	linuxDataPartitionUUID = "0FC63DAF-8483-4772-8E79-3D69D8477DE4"
)

func GetDataMount() (*mountinfo.Mountinfo, error) {

minfo, err := mountinfo.GetMountInfo("/proc/self/mountinfo")
	if err != nil {
		logging.Warning.Print(err)
		return nil, err
	}

for _, info := range minfo {
		if dataMount == info.MountPoint {
			return &info, nil
		}
	}
	return nil, errors.New("Can't find a data mount!")
}

type datadisk struct {
	conn  *dbus.Conn
	props *prop.Properties
}

func (d datadisk) MarkDataMove() *dbus.Error {
	/* Move request marker for hassos-data.service */
	fileName := "/mnt/overlay/move-data"
	_, err := os.Stat(fileName)
	if os.IsNotExist(err) {
		file, err := os.Create(fileName)
		if err != nil {
			return dbus.MakeFailedError(err)
		}
		defer file.Close()
	}

return nil
}

func (d datadisk) ChangeDevice(newDevice string) (bool, *dbus.Error) {
	logging.Info.Printf("Request to change data disk to %s.", newDevice)

udisks2helper := udisks2.NewUDisks2(d.conn)
	dataDevice, err := udisks2helper.GetRootDeviceFromLabel("hassos-data")
	if err != nil {
		return false, dbus.MakeFailedError(err)
	}

logging.Info.Printf("Data partition is currently on device %s.", *dataDevice)
	if *dataDevice == newDevice {
		return false, dbus.MakeFailedError(fmt.Errorf("Current data device \"%s\" the same as target device. Aborting.", *dataDevice))
	}

err = udisks2helper.PartitionDeviceWithSinglePartition(newDevice, linuxDataPartitionUUID, "hassos-data-external")
	if err != nil {
		return false, dbus.MakeFailedError(err)
	}

dbuserr := d.MarkDataMove()
	if dbuserr != nil {
		return false, dbuserr
	}

return true, nil
}

func (d datadisk) ReloadDevice() (bool, *dbus.Error) {
	mountInfo, err := GetDataMount()
	if err != nil {
		return false, dbus.MakeFailedError(err)
	}

d.props.SetMust(ifaceName, "CurrentDevice", mountInfo.MountSource)
	return true, nil
}

const (
	objectPath = "/io/hass/os/DataDisk"
	ifaceName  = "io.hass.os.DataDisk"
)

func InitializeDBus(conn *dbus.Conn) {

// Try to read the current data mount point
	mountInfo, err := GetDataMount()
	var currentDisk string = ""
	if err != nil {
		logging.Warning.Print(err)
	} else {
		currentDisk = mountInfo.MountSource
	}

d := datadisk{
		conn: conn,
	}

propsSpec := map[string]map[string]*prop.Prop{
		ifaceName: {
			"CurrentDevice": {
				Value:    &currentDisk,
				Writable: false,
				Emit:     prop.EmitTrue,
				Callback: nil,
			},
		},
	}
	props, err := prop.Export(conn, objectPath, propsSpec)
	if err != nil {
		logging.Critical.Panic(err)
	}
	d.props = props

err = conn.Export(d, objectPath, ifaceName)
	if err != nil {
		logging.Critical.Panic(err)
	}

err = conn.Export(introspect.NewIntrospectable(node), objectPath, "org.freedesktop.DBus.Introspectable")
	if err != nil {
		logging.Critical.Panic(err)
	}

logging.Info.Printf("Exposing object %s with interface %s ...", objectPath, ifaceName)
}
07070100000026000081A400000000000000000000000164F6FC38000001B1000000000000000000000000000000000000002400000000homeassistant-os-agent-1.6.0/go.modmodule github.com/home-assistant/os-agent

go 1.19

require (
	github.com/coreos/go-systemd/v22 v22.5.0
	github.com/cyphar/filepath-securejoin v0.2.3
	github.com/fntlnz/mountinfo v1.0.1
	github.com/getsentry/sentry-go v0.23.0
	github.com/godbus/dbus/v5 v5.1.0
	github.com/natefinch/atomic v1.0.1
	github.com/opencontainers/runtime-spec v1.1.0
)

require (
	golang.org/x/sys v0.6.0 // indirect
	golang.org/x/text v0.8.0 // indirect
)
07070100000027000081A400000000000000000000000164F6FC3800000901000000000000000000000000000000000000002400000000homeassistant-os-agent-1.6.0/go.sumgithub.com/coreos/go-systemd/v22 v22.5.0 h1:RrqgGjYQKalulkV8NGVIfkXQf6YYmOyiJKk8iXXhfZs=
github.com/coreos/go-systemd/v22 v22.5.0/go.mod h1:Y58oyj3AT4RCenI/lSvhwexgC+NSVTIJ3seZv2GcEnc=
github.com/cyphar/filepath-securejoin v0.2.3 h1:YX6ebbZCZP7VkM3scTTokDgBL2TY741X51MTk3ycuNI=
github.com/cyphar/filepath-securejoin v0.2.3/go.mod h1:aPGpWjXOXUn2NCNjFvBE6aRxGGx79pTxQpKOJNYHHl4=
github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
github.com/fntlnz/mountinfo v1.0.1 h1:I06izqp+/BwMPjdhuNnCZWOaOs5EaFFLXKdFB/lfKxk=
github.com/fntlnz/mountinfo v1.0.1/go.mod h1:k6q/bWiHuceDCdNRih4YtGy99p8LROjL5dBH6D9/lhg=
github.com/getsentry/sentry-go v0.23.0 h1:dn+QRCeJv4pPt9OjVXiMcGIBIefaTJPw/h0bZWO05nE=
github.com/getsentry/sentry-go v0.23.0/go.mod h1:lc76E2QywIyW8WuBnwl8Lc4bkmQH4+w1gwTf25trprY=
github.com/go-errors/errors v1.4.2 h1:J6MZopCL4uSllY1OfXM374weqZFFItUbrImctkmUxIA=
github.com/godbus/dbus/v5 v5.0.4/go.mod h1:xhWf0FNVPg57R7Z0UbKHbJfkEywrmjJnf7w5xrFpKfA=
github.com/godbus/dbus/v5 v5.1.0 h1:4KLkAxT3aOY8Li4FRJe/KvhoNFFxo0m6fNuFUO8QJUk=
github.com/godbus/dbus/v5 v5.1.0/go.mod h1:xhWf0FNVPg57R7Z0UbKHbJfkEywrmjJnf7w5xrFpKfA=
github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38=
github.com/natefinch/atomic v1.0.1 h1:ZPYKxkqQOx3KZ+RsbnP/YsgvxWQPGxjC0oBt2AhwV0A=
github.com/natefinch/atomic v1.0.1/go.mod h1:N/D/ELrljoqDyT3rZrsUmtsuzvHkeB/wWjHV22AZRbM=
github.com/opencontainers/runtime-spec v1.1.0 h1:HHUyrt9mwHUjtasSbXSMvs4cyFxh+Bll4AjJ9odEGpg=
github.com/opencontainers/runtime-spec v1.1.0/go.mod h1:jwyrGlmzljRJv/Fgzds9SsS/C5hL+LL3ko9hs6T5lQ0=
github.com/pingcap/errors v0.11.4 h1:lFuQV/oaUMGcD2tqt+01ROSmJs75VG1ToEOkZIZ4nE4=
github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4=
github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
github.com/stretchr/testify v1.8.2 h1:+h33VjcLVPDHtOdpUCuF+7gSuG3yGIftsP1YvFihtJ8=
golang.org/x/sys v0.6.0 h1:MVltZSvRTcU2ljQOhs94SXPftV6DCNnZViHeQps87pQ=
golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
golang.org/x/text v0.8.0 h1:57P1ETyNKtuIjB4SRd15iJxuhj8Gc416Y78H3qgMh68=
golang.org/x/text v0.8.0/go.mod h1:e1OnstbJyHTd6l/uOt8jFFHp6TRDWZR/bV3emEE/zU8=
gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
07070100000028000081A400000000000000000000000164F6FC3800000BB0000000000000000000000000000000000000002500000000homeassistant-os-agent-1.6.0/main.gopackage main

import (
	"time"

"github.com/coreos/go-systemd/v22/daemon"
	"github.com/getsentry/sentry-go"
	"github.com/godbus/dbus/v5"
	"github.com/godbus/dbus/v5/introspect"
	"github.com/godbus/dbus/v5/prop"

"github.com/home-assistant/os-agent/apparmor"
	"github.com/home-assistant/os-agent/boards"
	"github.com/home-assistant/os-agent/cgroup"
	"github.com/home-assistant/os-agent/datadisk"
	"github.com/home-assistant/os-agent/system"
	logging "github.com/home-assistant/os-agent/utils/log"
)

const (
	busName    = "io.hass.os"
	objectPath = "/io/hass/os"
	sentryDsn  = "https://c74e811a96e4413a95caaaa5ae05f851@o427061.ingest.sentry.io/5710878"
)

var (
	// version and baord are set at link time via -X flag
	version       string = "dev"
	board         string = "unknown"
	enableCapture bool   = false
)

func main() {
	logging.Info.Printf("Start OS-Agent %s", version)

// Sentry
	err := sentry.Init(sentry.ClientOptions{
		Dsn:        sentryDsn,
		Release:    version,
		BeforeSend: filterSentry,
	})
	if err != nil {
		logging.Critical.Fatalf("Sentry init: %s", err)
	}

defer sentry.Flush(2 * time.Second)
	defer sentry.Recover()

// Connect DBus
	conn, err := dbus.SystemBus()
	if err != nil {
		logging.Critical.Fatalf("DBus connection: %s", err)
	}

// Init Dbus io.hass.os
	reply, err := conn.RequestName(busName, dbus.NameFlagDoNotQueue)
	if err != nil {
		logging.Critical.Panic(err)
	}
	if reply != dbus.RequestNameReplyPrimaryOwner {
		logging.Critical.Fatalf("name already taken")
	}

// Set base Property / functionality
	InitializeDBus(conn)

logging.Info.Printf("Listening on service %s ...", busName)
	datadisk.InitializeDBus(conn)
	system.InitializeDBus(conn)
	apparmor.InitializeDBus(conn)
	cgroup.InitializeDBus(conn)
	boards.InitializeDBus(conn, board)

_, err = daemon.SdNotify(false, daemon.SdNotifyReady)
	if err != nil {
		logging.Critical.Panic(err)
	}
	select {}
}

func InitializeDBus(conn *dbus.Conn) {
	propsSpec := map[string]map[string]*prop.Prop{
		busName: {
			"Version": {
				Value:    version,
				Writable: false,
				Emit:     prop.EmitInvalidates,
				Callback: nil,
			},
			"Diagnostics": {
				Value:    enableCapture,
				Writable: true,
				Emit:     prop.EmitTrue,
				Callback: func(c *prop.Change) *dbus.Error {
					logging.Info.Printf("Diagnostics is now %t", c.Value)
					enableCapture = c.Value.(bool)
					return nil
				},
			},
		},
	}

props, err := prop.Export(conn, objectPath, propsSpec)
	if err != nil {
		logging.Critical.Panic(err)
	}

node := &introspect.Node{
		Name: objectPath,
		Interfaces: []introspect.Interface{
			introspect.IntrospectData,
			prop.IntrospectData,
			{
				Name:       busName,
				Properties: props.Introspection(busName),
			},
		},
	}
	err = conn.Export(introspect.NewIntrospectable(node), objectPath, "org.freedesktop.DBus.Introspectable")
	if err != nil {
		logging.Critical.Panic(err)
	}

logging.Info.Printf("Exposing object %s with interface %s ...", objectPath, busName)
}
07070100000029000081A400000000000000000000000164F6FC38000000CF000000000000000000000000000000000000002700000000homeassistant-os-agent-1.6.0/sentry.gopackage main

import "github.com/getsentry/sentry-go"

func filterSentry(event *sentry.Event, hint *sentry.EventHint) *sentry.Event {
	if version == "dev" || !enableCapture {
		return nil
	}
	return event
}
0707010000002A000041ED00000000000000000000000264F6FC3800000000000000000000000000000000000000000000002400000000homeassistant-os-agent-1.6.0/system0707010000002B000081A400000000000000000000000164F6FC38000010E9000000000000000000000000000000000000002E00000000homeassistant-os-agent-1.6.0/system/system.gopackage system

import (
	"context"
	"fmt"
	"os"
	"strings"

"github.com/godbus/dbus/v5"
	"github.com/godbus/dbus/v5/introspect"
	"github.com/godbus/dbus/v5/prop"

"github.com/home-assistant/os-agent/udisks2"
	logging "github.com/home-assistant/os-agent/utils/log"
)

const (
	objectPath             = "/io/hass/os/System"
	ifaceName              = "io.hass.os.System"
	labelDataFileSystem    = "hassos-data"
	labelOverlayFileSystem = "hassos-overlay"
	kernelCommandLine      = "/mnt/boot/cmdline.txt"
	tmpKernelCommandLine   = "/mnt/boot/.tmp.cmdline.txt"
	sshAuthKeyFileName     = "/root/.ssh/authorized_keys"
)

type system struct {
	conn *dbus.Conn
}

func getAndCheckBusObjectFromLabel(udisks2helper udisks2.UDisks2Helper, label string) (dbus.BusObject, error) {
	dataBusObject, err := udisks2helper.GetBusObjectFromLabel(label)
	if err != nil {
		return nil, dbus.MakeFailedError(err)
	}

dataFilesystem := udisks2.NewFilesystem(dataBusObject)
	dataMountPoints, err := dataFilesystem.GetMountPointsString(context.Background())
	if err != nil {
		return nil, dbus.MakeFailedError(err)
	}

if len(dataMountPoints) > 0 {
		return nil, dbus.MakeFailedError(fmt.Errorf("Device with label \"%s\" is mounted at %s, aborting.", label, dataMountPoints))
	}

return dataBusObject, nil
}

func (d system) WipeDevice() (bool, *dbus.Error) {
	logging.Info.Printf("Wipe device data.")

udisks2helper := udisks2.NewUDisks2(d.conn)
	dataBusObject, err := getAndCheckBusObjectFromLabel(udisks2helper, labelDataFileSystem)
	if err != nil {
		return false, dbus.MakeFailedError(err)
	}

overlayBusObject, err := getAndCheckBusObjectFromLabel(udisks2helper, labelOverlayFileSystem)
	if err != nil {
		return false, dbus.MakeFailedError(err)
	}

err = udisks2helper.FormatPartition(dataBusObject, "ext4", labelDataFileSystem)
	if err != nil {
		return false, dbus.MakeFailedError(err)
	}
	err = udisks2helper.FormatPartition(overlayBusObject, "ext4", labelOverlayFileSystem)
	if err != nil {
		return false, dbus.MakeFailedError(err)
	}
	logging.Info.Printf("Successfully wiped device data.")

return true, nil
}

func (d system) ScheduleWipeDevice() (bool, *dbus.Error) {

data, err := os.ReadFile(kernelCommandLine)
	if err != nil {
		fmt.Println(err)
		return false, dbus.MakeFailedError(err)
	}

datastr := strings.TrimSpace(string(data))
	datastr += " haos.wipe=1"

err = os.WriteFile(tmpKernelCommandLine, []byte(datastr), 0644) //nolint:gosec
	if err != nil {
		fmt.Println(err)
		return false, dbus.MakeFailedError(err)
	}

// Boot is mounted sync on Home Assistant OS, so just rename should be fine.
	err = os.Rename(tmpKernelCommandLine, kernelCommandLine)
	if err != nil {
		fmt.Println(err)
		return false, dbus.MakeFailedError(err)
	}

logging.Info.Printf("Device will get wiped on next reboot!")
	return true, nil
}

func (d system) AddSSHAuthKey(newKey string) *dbus.Error {

file, err := os.OpenFile(sshAuthKeyFileName, os.O_APPEND|os.O_CREATE|os.O_WRONLY, 0644)
	if err != nil {
		logging.Error.Printf("Failed to open SSH authentication file %s: %s", sshAuthKeyFileName, err)
		return dbus.MakeFailedError(err)
	}

defer file.Close()

if _, err := file.WriteString(newKey + "\n"); err != nil {
		logging.Error.Printf("Failed to write SSH authentication file: %s.", err)
		return dbus.MakeFailedError(err)
	}

logging.Info.Printf("New SSH authentication key added for user root.")

return nil
}

func (d system) ClearSSHAuthKeys() *dbus.Error {
	if err := os.Remove(sshAuthKeyFileName); err != nil && os.IsNotExist(err) {
		logging.Error.Printf("Failed to delete SSH authentication file %s: %s", sshAuthKeyFileName, err)
		return dbus.MakeFailedError(err)
	}

return nil
}

func InitializeDBus(conn *dbus.Conn) {
	d := system{
		conn: conn,
	}

err := conn.Export(d, objectPath, ifaceName)
	if err != nil {
		logging.Critical.Panic(err)
	}

node := &introspect.Node{
		Name: objectPath,
		Interfaces: []introspect.Interface{
			introspect.IntrospectData,
			prop.IntrospectData,
			{
				Name:    ifaceName,
				Methods: introspect.Methods(d),
			},
		},
	}

err = conn.Export(introspect.NewIntrospectable(node), objectPath, "org.freedesktop.DBus.Introspectable")
	if err != nil {
		logging.Critical.Panic(err)
	}

logging.Info.Printf("Exposing object %s with interface %s ...", objectPath, ifaceName)
}
0707010000002C000041ED00000000000000000000000264F6FC3800000000000000000000000000000000000000000000002500000000homeassistant-os-agent-1.6.0/udisks20707010000002D000081A400000000000000000000000164F6FC38000104BD000000000000000000000000000000000000002C00000000homeassistant-os-agent-1.6.0/udisks2/api.go// Code generated by dbus-codegen-go DO NOT EDIT.
package udisks2

import (
	"context"
	"errors"
	"fmt"
	"github.com/godbus/dbus/v5"
)

// Signal is a common interface for all signals.
type Signal interface {
	Name() string
	Interface() string
	Sender() string

path() dbus.ObjectPath
	values() []interface{}
}

// ErrUnknownSignal is returned by LookupSignal when a signal cannot be resolved.
var ErrUnknownSignal = errors.New("unknown signal")

// LookupSignal converts the given raw D-Bus signal with variable body
// into one with typed structured body or returns ErrUnknownSignal error.
func LookupSignal(signal *dbus.Signal) (Signal, error) {
	switch signal.Name {
	case InterfaceJob + "." + "Completed":
		v0, ok := signal.Body[0].(bool)
		if !ok {
			return nil, fmt.Errorf("prop .Success is %T, not bool", signal.Body[0])
		}
		v1, ok := signal.Body[1].(string)
		if !ok {
			return nil, fmt.Errorf("prop .Message is %T, not string", signal.Body[1])
		}
		return &JobCompletedSignal{
			sender: signal.Sender,
			Path:   signal.Path,
			Body: &JobCompletedSignalBody{
				Success: v0,
				Message: v1,
			},
		}, nil
	default:
		return nil, ErrUnknownSignal
	}
}

// AddMatchSignal registers a match rule for the given signal,
// opts are appended to the automatically generated signal's rules.
func AddMatchSignal(conn *dbus.Conn, s Signal, opts ...dbus.MatchOption) error {
	return conn.AddMatchSignal(append([]dbus.MatchOption{
		dbus.WithMatchInterface(s.Interface()),
		dbus.WithMatchMember(s.Name()),
	}, opts...)...)
}

// RemoveMatchSignal unregisters the previously registered subscription.
func RemoveMatchSignal(conn *dbus.Conn, s Signal, opts ...dbus.MatchOption) error {
	return conn.RemoveMatchSignal(append([]dbus.MatchOption{
		dbus.WithMatchInterface(s.Interface()),
		dbus.WithMatchMember(s.Name()),
	}, opts...)...)
}

// Interface name constants.
const (
	InterfaceManager        = "org.freedesktop.UDisks2.Manager"
	InterfaceDrive          = "org.freedesktop.UDisks2.Drive"
	InterfaceDriveAta       = "org.freedesktop.UDisks2.Drive.Ata"
	InterfaceBlock          = "org.freedesktop.UDisks2.Block"
	InterfacePartitionTable = "org.freedesktop.UDisks2.PartitionTable"
	InterfacePartition      = "org.freedesktop.UDisks2.Partition"
	InterfaceFilesystem     = "org.freedesktop.UDisks2.Filesystem"
	InterfaceSwapspace      = "org.freedesktop.UDisks2.Swapspace"
	InterfaceEncrypted      = "org.freedesktop.UDisks2.Encrypted"
	InterfaceLoop           = "org.freedesktop.UDisks2.Loop"
	InterfaceMDRaid         = "org.freedesktop.UDisks2.MDRaid"
	InterfaceJob            = "org.freedesktop.UDisks2.Job"
)

// NewManager creates and allocates org.freedesktop.UDisks2.Manager.
func NewManager(object dbus.BusObject) *Manager {
	return &Manager{object}
}

// Manager implements org.freedesktop.UDisks2.Manager D-Bus interface.
type Manager struct {
	object dbus.BusObject
}

// CanFormat calls org.freedesktop.UDisks2.Manager.CanFormat method.
func (o *Manager) CanFormat(ctx context.Context, inType string) (available struct {
	V0 bool
	V1 string
}, err error) {
	err = o.object.CallWithContext(ctx, InterfaceManager+".CanFormat", 0, inType).Store(&available)
	return
}

// CanResize calls org.freedesktop.UDisks2.Manager.CanResize method.
func (o *Manager) CanResize(ctx context.Context, inType string) (available struct {
	V0 bool
	V1 uint64
	V2 string
}, err error) {
	err = o.object.CallWithContext(ctx, InterfaceManager+".CanResize", 0, inType).Store(&available)
	return
}

// CanCheck calls org.freedesktop.UDisks2.Manager.CanCheck method.
func (o *Manager) CanCheck(ctx context.Context, inType string) (available struct {
	V0 bool
	V1 string
}, err error) {
	err = o.object.CallWithContext(ctx, InterfaceManager+".CanCheck", 0, inType).Store(&available)
	return
}

// CanRepair calls org.freedesktop.UDisks2.Manager.CanRepair method.
func (o *Manager) CanRepair(ctx context.Context, inType string) (available struct {
	V0 bool
	V1 string
}, err error) {
	err = o.object.CallWithContext(ctx, InterfaceManager+".CanRepair", 0, inType).Store(&available)
	return
}

// LoopSetup calls org.freedesktop.UDisks2.Manager.LoopSetup method.
//
// Annotations:
//   @org.gtk.GDBus.C.UnixFD = 1
func (o *Manager) LoopSetup(ctx context.Context, fd dbus.UnixFD, options map[string]dbus.Variant) (resultingDevice dbus.ObjectPath, err error) {
	err = o.object.CallWithContext(ctx, InterfaceManager+".LoopSetup", 0, fd, options).Store(&resultingDevice)
	return
}

// MDRaidCreate calls org.freedesktop.UDisks2.Manager.MDRaidCreate method.
func (o *Manager) MDRaidCreate(ctx context.Context, blocks []dbus.ObjectPath, level string, name string, chunk uint64, options map[string]dbus.Variant) (resultingArray dbus.ObjectPath, err error) {
	err = o.object.CallWithContext(ctx, InterfaceManager+".MDRaidCreate", 0, blocks, level, name, chunk, options).Store(&resultingArray)
	return
}

// EnableModules calls org.freedesktop.UDisks2.Manager.EnableModules method.
//
// Deprecated will be removed later.
//
// Annotations:
//   @org.freedesktop.DBus.Deprecated = true
func (o *Manager) EnableModules(ctx context.Context, enable bool) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceManager+".EnableModules", 0, enable).Store()
	return
}

// EnableModule calls org.freedesktop.UDisks2.Manager.EnableModule method.
func (o *Manager) EnableModule(ctx context.Context, name string, enable bool) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceManager+".EnableModule", 0, name, enable).Store()
	return
}

// GetBlockDevices calls org.freedesktop.UDisks2.Manager.GetBlockDevices method.
func (o *Manager) GetBlockDevices(ctx context.Context, options map[string]dbus.Variant) (blockObjects []dbus.ObjectPath, err error) {
	err = o.object.CallWithContext(ctx, InterfaceManager+".GetBlockDevices", 0, options).Store(&blockObjects)
	return
}

// ResolveDevice calls org.freedesktop.UDisks2.Manager.ResolveDevice method.
func (o *Manager) ResolveDevice(ctx context.Context, devspec map[string]dbus.Variant, options map[string]dbus.Variant) (devices []dbus.ObjectPath, err error) {
	err = o.object.CallWithContext(ctx, InterfaceManager+".ResolveDevice", 0, devspec, options).Store(&devices)
	return
}

// GetVersion gets org.freedesktop.UDisks2.Manager.Version property.
func (o *Manager) GetVersion(ctx context.Context) (version string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceManager, "Version").Store(&version)
	return
}

// GetSupportedFilesystems gets org.freedesktop.UDisks2.Manager.SupportedFilesystems property.
func (o *Manager) GetSupportedFilesystems(ctx context.Context) (supportedFilesystems []string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceManager, "SupportedFilesystems").Store(&supportedFilesystems)
	return
}

// GetSupportedEncryptionTypes gets org.freedesktop.UDisks2.Manager.SupportedEncryptionTypes property.
func (o *Manager) GetSupportedEncryptionTypes(ctx context.Context) (supportedEncryptionTypes []string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceManager, "SupportedEncryptionTypes").Store(&supportedEncryptionTypes)
	return
}

// GetDefaultEncryptionType gets org.freedesktop.UDisks2.Manager.DefaultEncryptionType property.
func (o *Manager) GetDefaultEncryptionType(ctx context.Context) (defaultEncryptionType string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceManager, "DefaultEncryptionType").Store(&defaultEncryptionType)
	return
}

// NewDrive creates and allocates org.freedesktop.UDisks2.Drive.
func NewDrive(object dbus.BusObject) *Drive {
	return &Drive{object}
}

// Drive implements org.freedesktop.UDisks2.Drive D-Bus interface.
type Drive struct {
	object dbus.BusObject
}

// Eject calls org.freedesktop.UDisks2.Drive.Eject method.
func (o *Drive) Eject(ctx context.Context, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceDrive+".Eject", 0, options).Store()
	return
}

// SetConfiguration calls org.freedesktop.UDisks2.Drive.SetConfiguration method.
func (o *Drive) SetConfiguration(ctx context.Context, value map[string]dbus.Variant, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceDrive+".SetConfiguration", 0, value, options).Store()
	return
}

// PowerOff calls org.freedesktop.UDisks2.Drive.PowerOff method.
func (o *Drive) PowerOff(ctx context.Context, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceDrive+".PowerOff", 0, options).Store()
	return
}

// GetVendor gets org.freedesktop.UDisks2.Drive.Vendor property.
func (o *Drive) GetVendor(ctx context.Context) (vendor string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDrive, "Vendor").Store(&vendor)
	return
}

// GetModel gets org.freedesktop.UDisks2.Drive.Model property.
func (o *Drive) GetModel(ctx context.Context) (model string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDrive, "Model").Store(&model)
	return
}

// GetRevision gets org.freedesktop.UDisks2.Drive.Revision property.
func (o *Drive) GetRevision(ctx context.Context) (revision string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDrive, "Revision").Store(&revision)
	return
}

// GetSerial gets org.freedesktop.UDisks2.Drive.Serial property.
func (o *Drive) GetSerial(ctx context.Context) (serial string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDrive, "Serial").Store(&serial)
	return
}

// GetWWN gets org.freedesktop.UDisks2.Drive.WWN property.
func (o *Drive) GetWWN(ctx context.Context) (wWN string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDrive, "WWN").Store(&wWN)
	return
}

// GetId gets org.freedesktop.UDisks2.Drive.Id property.
func (o *Drive) GetId(ctx context.Context) (id string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDrive, "Id").Store(&id)
	return
}

// GetConfiguration gets org.freedesktop.UDisks2.Drive.Configuration property.
func (o *Drive) GetConfiguration(ctx context.Context) (configuration map[string]dbus.Variant, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDrive, "Configuration").Store(&configuration)
	return
}

// GetMedia gets org.freedesktop.UDisks2.Drive.Media property.
func (o *Drive) GetMedia(ctx context.Context) (media string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDrive, "Media").Store(&media)
	return
}

// GetMediaCompatibility gets org.freedesktop.UDisks2.Drive.MediaCompatibility property.
func (o *Drive) GetMediaCompatibility(ctx context.Context) (mediaCompatibility []string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDrive, "MediaCompatibility").Store(&mediaCompatibility)
	return
}

// GetMediaRemovable gets org.freedesktop.UDisks2.Drive.MediaRemovable property.
func (o *Drive) GetMediaRemovable(ctx context.Context) (mediaRemovable bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDrive, "MediaRemovable").Store(&mediaRemovable)
	return
}

// GetMediaAvailable gets org.freedesktop.UDisks2.Drive.MediaAvailable property.
func (o *Drive) GetMediaAvailable(ctx context.Context) (mediaAvailable bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDrive, "MediaAvailable").Store(&mediaAvailable)
	return
}

// GetMediaChangeDetected gets org.freedesktop.UDisks2.Drive.MediaChangeDetected property.
func (o *Drive) GetMediaChangeDetected(ctx context.Context) (mediaChangeDetected bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDrive, "MediaChangeDetected").Store(&mediaChangeDetected)
	return
}

// GetSize gets org.freedesktop.UDisks2.Drive.Size property.
func (o *Drive) GetSize(ctx context.Context) (size uint64, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDrive, "Size").Store(&size)
	return
}

// GetTimeDetected gets org.freedesktop.UDisks2.Drive.TimeDetected property.
func (o *Drive) GetTimeDetected(ctx context.Context) (timeDetected uint64, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDrive, "TimeDetected").Store(&timeDetected)
	return
}

// GetTimeMediaDetected gets org.freedesktop.UDisks2.Drive.TimeMediaDetected property.
func (o *Drive) GetTimeMediaDetected(ctx context.Context) (timeMediaDetected uint64, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDrive, "TimeMediaDetected").Store(&timeMediaDetected)
	return
}

// GetOptical gets org.freedesktop.UDisks2.Drive.Optical property.
func (o *Drive) GetOptical(ctx context.Context) (optical bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDrive, "Optical").Store(&optical)
	return
}

// GetOpticalBlank gets org.freedesktop.UDisks2.Drive.OpticalBlank property.
func (o *Drive) GetOpticalBlank(ctx context.Context) (opticalBlank bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDrive, "OpticalBlank").Store(&opticalBlank)
	return
}

// GetOpticalNumTracks gets org.freedesktop.UDisks2.Drive.OpticalNumTracks property.
func (o *Drive) GetOpticalNumTracks(ctx context.Context) (opticalNumTracks uint32, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDrive, "OpticalNumTracks").Store(&opticalNumTracks)
	return
}

// GetOpticalNumAudioTracks gets org.freedesktop.UDisks2.Drive.OpticalNumAudioTracks property.
func (o *Drive) GetOpticalNumAudioTracks(ctx context.Context) (opticalNumAudioTracks uint32, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDrive, "OpticalNumAudioTracks").Store(&opticalNumAudioTracks)
	return
}

// GetOpticalNumDataTracks gets org.freedesktop.UDisks2.Drive.OpticalNumDataTracks property.
func (o *Drive) GetOpticalNumDataTracks(ctx context.Context) (opticalNumDataTracks uint32, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDrive, "OpticalNumDataTracks").Store(&opticalNumDataTracks)
	return
}

// GetOpticalNumSessions gets org.freedesktop.UDisks2.Drive.OpticalNumSessions property.
func (o *Drive) GetOpticalNumSessions(ctx context.Context) (opticalNumSessions uint32, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDrive, "OpticalNumSessions").Store(&opticalNumSessions)
	return
}

// GetRotationRate gets org.freedesktop.UDisks2.Drive.RotationRate property.
func (o *Drive) GetRotationRate(ctx context.Context) (rotationRate int32, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDrive, "RotationRate").Store(&rotationRate)
	return
}

// GetConnectionBus gets org.freedesktop.UDisks2.Drive.ConnectionBus property.
func (o *Drive) GetConnectionBus(ctx context.Context) (connectionBus string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDrive, "ConnectionBus").Store(&connectionBus)
	return
}

// GetSeat gets org.freedesktop.UDisks2.Drive.Seat property.
func (o *Drive) GetSeat(ctx context.Context) (seat string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDrive, "Seat").Store(&seat)
	return
}

// GetRemovable gets org.freedesktop.UDisks2.Drive.Removable property.
func (o *Drive) GetRemovable(ctx context.Context) (removable bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDrive, "Removable").Store(&removable)
	return
}

// GetEjectable gets org.freedesktop.UDisks2.Drive.Ejectable property.
func (o *Drive) GetEjectable(ctx context.Context) (ejectable bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDrive, "Ejectable").Store(&ejectable)
	return
}

// GetSortKey gets org.freedesktop.UDisks2.Drive.SortKey property.
func (o *Drive) GetSortKey(ctx context.Context) (sortKey string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDrive, "SortKey").Store(&sortKey)
	return
}

// GetCanPowerOff gets org.freedesktop.UDisks2.Drive.CanPowerOff property.
func (o *Drive) GetCanPowerOff(ctx context.Context) (canPowerOff bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDrive, "CanPowerOff").Store(&canPowerOff)
	return
}

// GetSiblingId gets org.freedesktop.UDisks2.Drive.SiblingId property.
func (o *Drive) GetSiblingId(ctx context.Context) (siblingId string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDrive, "SiblingId").Store(&siblingId)
	return
}

// NewDriveAta creates and allocates org.freedesktop.UDisks2.Drive.Ata.
func NewDriveAta(object dbus.BusObject) *DriveAta {
	return &DriveAta{object}
}

// DriveAta implements org.freedesktop.UDisks2.Drive.Ata D-Bus interface.
type DriveAta struct {
	object dbus.BusObject
}

// SmartUpdate calls org.freedesktop.UDisks2.Drive.Ata.SmartUpdate method.
func (o *DriveAta) SmartUpdate(ctx context.Context, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceDriveAta+".SmartUpdate", 0, options).Store()
	return
}

// SmartGetAttributes calls org.freedesktop.UDisks2.Drive.Ata.SmartGetAttributes method.
func (o *DriveAta) SmartGetAttributes(ctx context.Context, options map[string]dbus.Variant) (attributes []struct {
	V0 byte
	V1 string
	V2 uint16
	V3 int32
	V4 int32
	V5 int32
	V6 int64
	V7 int32
	V8 map[string]dbus.Variant
}, err error) {
	err = o.object.CallWithContext(ctx, InterfaceDriveAta+".SmartGetAttributes", 0, options).Store(&attributes)
	return
}

// SmartSelftestStart calls org.freedesktop.UDisks2.Drive.Ata.SmartSelftestStart method.
func (o *DriveAta) SmartSelftestStart(ctx context.Context, inType string, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceDriveAta+".SmartSelftestStart", 0, inType, options).Store()
	return
}

// SmartSelftestAbort calls org.freedesktop.UDisks2.Drive.Ata.SmartSelftestAbort method.
func (o *DriveAta) SmartSelftestAbort(ctx context.Context, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceDriveAta+".SmartSelftestAbort", 0, options).Store()
	return
}

// SmartSetEnabled calls org.freedesktop.UDisks2.Drive.Ata.SmartSetEnabled method.
func (o *DriveAta) SmartSetEnabled(ctx context.Context, value bool, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceDriveAta+".SmartSetEnabled", 0, value, options).Store()
	return
}

// PmGetState calls org.freedesktop.UDisks2.Drive.Ata.PmGetState method.
func (o *DriveAta) PmGetState(ctx context.Context, options map[string]dbus.Variant) (state byte, err error) {
	err = o.object.CallWithContext(ctx, InterfaceDriveAta+".PmGetState", 0, options).Store(&state)
	return
}

// PmStandby calls org.freedesktop.UDisks2.Drive.Ata.PmStandby method.
func (o *DriveAta) PmStandby(ctx context.Context, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceDriveAta+".PmStandby", 0, options).Store()
	return
}

// PmWakeup calls org.freedesktop.UDisks2.Drive.Ata.PmWakeup method.
func (o *DriveAta) PmWakeup(ctx context.Context, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceDriveAta+".PmWakeup", 0, options).Store()
	return
}

// SecurityEraseUnit calls org.freedesktop.UDisks2.Drive.Ata.SecurityEraseUnit method.
func (o *DriveAta) SecurityEraseUnit(ctx context.Context, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceDriveAta+".SecurityEraseUnit", 0, options).Store()
	return
}

// GetSmartSupported gets org.freedesktop.UDisks2.Drive.Ata.SmartSupported property.
func (o *DriveAta) GetSmartSupported(ctx context.Context) (smartSupported bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDriveAta, "SmartSupported").Store(&smartSupported)
	return
}

// GetSmartEnabled gets org.freedesktop.UDisks2.Drive.Ata.SmartEnabled property.
func (o *DriveAta) GetSmartEnabled(ctx context.Context) (smartEnabled bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDriveAta, "SmartEnabled").Store(&smartEnabled)
	return
}

// GetSmartUpdated gets org.freedesktop.UDisks2.Drive.Ata.SmartUpdated property.
func (o *DriveAta) GetSmartUpdated(ctx context.Context) (smartUpdated uint64, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDriveAta, "SmartUpdated").Store(&smartUpdated)
	return
}

// GetSmartFailing gets org.freedesktop.UDisks2.Drive.Ata.SmartFailing property.
func (o *DriveAta) GetSmartFailing(ctx context.Context) (smartFailing bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDriveAta, "SmartFailing").Store(&smartFailing)
	return
}

// GetSmartPowerOnSeconds gets org.freedesktop.UDisks2.Drive.Ata.SmartPowerOnSeconds property.
func (o *DriveAta) GetSmartPowerOnSeconds(ctx context.Context) (smartPowerOnSeconds uint64, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDriveAta, "SmartPowerOnSeconds").Store(&smartPowerOnSeconds)
	return
}

// GetSmartTemperature gets org.freedesktop.UDisks2.Drive.Ata.SmartTemperature property.
func (o *DriveAta) GetSmartTemperature(ctx context.Context) (smartTemperature float64, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDriveAta, "SmartTemperature").Store(&smartTemperature)
	return
}

// GetSmartNumAttributesFailing gets org.freedesktop.UDisks2.Drive.Ata.SmartNumAttributesFailing property.
func (o *DriveAta) GetSmartNumAttributesFailing(ctx context.Context) (smartNumAttributesFailing int32, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDriveAta, "SmartNumAttributesFailing").Store(&smartNumAttributesFailing)
	return
}

// GetSmartNumAttributesFailedInThePast gets org.freedesktop.UDisks2.Drive.Ata.SmartNumAttributesFailedInThePast property.
func (o *DriveAta) GetSmartNumAttributesFailedInThePast(ctx context.Context) (smartNumAttributesFailedInThePast int32, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDriveAta, "SmartNumAttributesFailedInThePast").Store(&smartNumAttributesFailedInThePast)
	return
}

// GetSmartNumBadSectors gets org.freedesktop.UDisks2.Drive.Ata.SmartNumBadSectors property.
func (o *DriveAta) GetSmartNumBadSectors(ctx context.Context) (smartNumBadSectors int64, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDriveAta, "SmartNumBadSectors").Store(&smartNumBadSectors)
	return
}

// GetSmartSelftestStatus gets org.freedesktop.UDisks2.Drive.Ata.SmartSelftestStatus property.
func (o *DriveAta) GetSmartSelftestStatus(ctx context.Context) (smartSelftestStatus string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDriveAta, "SmartSelftestStatus").Store(&smartSelftestStatus)
	return
}

// GetSmartSelftestPercentRemaining gets org.freedesktop.UDisks2.Drive.Ata.SmartSelftestPercentRemaining property.
func (o *DriveAta) GetSmartSelftestPercentRemaining(ctx context.Context) (smartSelftestPercentRemaining int32, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDriveAta, "SmartSelftestPercentRemaining").Store(&smartSelftestPercentRemaining)
	return
}

// GetPmSupported gets org.freedesktop.UDisks2.Drive.Ata.PmSupported property.
func (o *DriveAta) GetPmSupported(ctx context.Context) (pmSupported bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDriveAta, "PmSupported").Store(&pmSupported)
	return
}

// GetPmEnabled gets org.freedesktop.UDisks2.Drive.Ata.PmEnabled property.
func (o *DriveAta) GetPmEnabled(ctx context.Context) (pmEnabled bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDriveAta, "PmEnabled").Store(&pmEnabled)
	return
}

// GetApmSupported gets org.freedesktop.UDisks2.Drive.Ata.ApmSupported property.
func (o *DriveAta) GetApmSupported(ctx context.Context) (apmSupported bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDriveAta, "ApmSupported").Store(&apmSupported)
	return
}

// GetApmEnabled gets org.freedesktop.UDisks2.Drive.Ata.ApmEnabled property.
func (o *DriveAta) GetApmEnabled(ctx context.Context) (apmEnabled bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDriveAta, "ApmEnabled").Store(&apmEnabled)
	return
}

// GetAamSupported gets org.freedesktop.UDisks2.Drive.Ata.AamSupported property.
func (o *DriveAta) GetAamSupported(ctx context.Context) (aamSupported bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDriveAta, "AamSupported").Store(&aamSupported)
	return
}

// GetAamEnabled gets org.freedesktop.UDisks2.Drive.Ata.AamEnabled property.
func (o *DriveAta) GetAamEnabled(ctx context.Context) (aamEnabled bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDriveAta, "AamEnabled").Store(&aamEnabled)
	return
}

// GetAamVendorRecommendedValue gets org.freedesktop.UDisks2.Drive.Ata.AamVendorRecommendedValue property.
func (o *DriveAta) GetAamVendorRecommendedValue(ctx context.Context) (aamVendorRecommendedValue int32, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDriveAta, "AamVendorRecommendedValue").Store(&aamVendorRecommendedValue)
	return
}

// GetWriteCacheSupported gets org.freedesktop.UDisks2.Drive.Ata.WriteCacheSupported property.
func (o *DriveAta) GetWriteCacheSupported(ctx context.Context) (writeCacheSupported bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDriveAta, "WriteCacheSupported").Store(&writeCacheSupported)
	return
}

// GetWriteCacheEnabled gets org.freedesktop.UDisks2.Drive.Ata.WriteCacheEnabled property.
func (o *DriveAta) GetWriteCacheEnabled(ctx context.Context) (writeCacheEnabled bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDriveAta, "WriteCacheEnabled").Store(&writeCacheEnabled)
	return
}

// GetReadLookaheadSupported gets org.freedesktop.UDisks2.Drive.Ata.ReadLookaheadSupported property.
func (o *DriveAta) GetReadLookaheadSupported(ctx context.Context) (readLookaheadSupported bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDriveAta, "ReadLookaheadSupported").Store(&readLookaheadSupported)
	return
}

// GetReadLookaheadEnabled gets org.freedesktop.UDisks2.Drive.Ata.ReadLookaheadEnabled property.
func (o *DriveAta) GetReadLookaheadEnabled(ctx context.Context) (readLookaheadEnabled bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDriveAta, "ReadLookaheadEnabled").Store(&readLookaheadEnabled)
	return
}

// GetSecurityEraseUnitMinutes gets org.freedesktop.UDisks2.Drive.Ata.SecurityEraseUnitMinutes property.
func (o *DriveAta) GetSecurityEraseUnitMinutes(ctx context.Context) (securityEraseUnitMinutes int32, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDriveAta, "SecurityEraseUnitMinutes").Store(&securityEraseUnitMinutes)
	return
}

// GetSecurityEnhancedEraseUnitMinutes gets org.freedesktop.UDisks2.Drive.Ata.SecurityEnhancedEraseUnitMinutes property.
func (o *DriveAta) GetSecurityEnhancedEraseUnitMinutes(ctx context.Context) (securityEnhancedEraseUnitMinutes int32, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDriveAta, "SecurityEnhancedEraseUnitMinutes").Store(&securityEnhancedEraseUnitMinutes)
	return
}

// GetSecurityFrozen gets org.freedesktop.UDisks2.Drive.Ata.SecurityFrozen property.
func (o *DriveAta) GetSecurityFrozen(ctx context.Context) (securityFrozen bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceDriveAta, "SecurityFrozen").Store(&securityFrozen)
	return
}

// NewBlock creates and allocates org.freedesktop.UDisks2.Block.
func NewBlock(object dbus.BusObject) *Block {
	return &Block{object}
}

// Block implements org.freedesktop.UDisks2.Block D-Bus interface.
type Block struct {
	object dbus.BusObject
}

// AddConfigurationItem calls org.freedesktop.UDisks2.Block.AddConfigurationItem method.
func (o *Block) AddConfigurationItem(ctx context.Context, item struct {
	V0 string
	V1 map[string]dbus.Variant
}, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceBlock+".AddConfigurationItem", 0, item, options).Store()
	return
}

// RemoveConfigurationItem calls org.freedesktop.UDisks2.Block.RemoveConfigurationItem method.
func (o *Block) RemoveConfigurationItem(ctx context.Context, item struct {
	V0 string
	V1 map[string]dbus.Variant
}, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceBlock+".RemoveConfigurationItem", 0, item, options).Store()
	return
}

// UpdateConfigurationItem calls org.freedesktop.UDisks2.Block.UpdateConfigurationItem method.
func (o *Block) UpdateConfigurationItem(ctx context.Context, oldItem struct {
	V0 string
	V1 map[string]dbus.Variant
}, newItem struct {
	V0 string
	V1 map[string]dbus.Variant
}, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceBlock+".UpdateConfigurationItem", 0, oldItem, newItem, options).Store()
	return
}

// GetSecretConfiguration calls org.freedesktop.UDisks2.Block.GetSecretConfiguration method.
func (o *Block) GetSecretConfiguration(ctx context.Context, options map[string]dbus.Variant) (configuration []struct {
	V0 string
	V1 map[string]dbus.Variant
}, err error) {
	err = o.object.CallWithContext(ctx, InterfaceBlock+".GetSecretConfiguration", 0, options).Store(&configuration)
	return
}

// Format calls org.freedesktop.UDisks2.Block.Format method.
func (o *Block) Format(ctx context.Context, inType string, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceBlock+".Format", 0, inType, options).Store()
	return
}

// OpenForBackup calls org.freedesktop.UDisks2.Block.OpenForBackup method.
//
// Annotations:
//   @org.gtk.GDBus.C.UnixFD = 1
func (o *Block) OpenForBackup(ctx context.Context, options map[string]dbus.Variant) (fd dbus.UnixFD, err error) {
	err = o.object.CallWithContext(ctx, InterfaceBlock+".OpenForBackup", 0, options).Store(&fd)
	return
}

// OpenForRestore calls org.freedesktop.UDisks2.Block.OpenForRestore method.
//
// Annotations:
//   @org.gtk.GDBus.C.UnixFD = 1
func (o *Block) OpenForRestore(ctx context.Context, options map[string]dbus.Variant) (fd dbus.UnixFD, err error) {
	err = o.object.CallWithContext(ctx, InterfaceBlock+".OpenForRestore", 0, options).Store(&fd)
	return
}

// OpenForBenchmark calls org.freedesktop.UDisks2.Block.OpenForBenchmark method.
//
// Annotations:
//   @org.gtk.GDBus.C.UnixFD = 1
func (o *Block) OpenForBenchmark(ctx context.Context, options map[string]dbus.Variant) (fd dbus.UnixFD, err error) {
	err = o.object.CallWithContext(ctx, InterfaceBlock+".OpenForBenchmark", 0, options).Store(&fd)
	return
}

// OpenDevice calls org.freedesktop.UDisks2.Block.OpenDevice method.
//
// Annotations:
//   @org.gtk.GDBus.C.UnixFD = 1
func (o *Block) OpenDevice(ctx context.Context, mode string, options map[string]dbus.Variant) (fd dbus.UnixFD, err error) {
	err = o.object.CallWithContext(ctx, InterfaceBlock+".OpenDevice", 0, mode, options).Store(&fd)
	return
}

// Rescan calls org.freedesktop.UDisks2.Block.Rescan method.
func (o *Block) Rescan(ctx context.Context, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceBlock+".Rescan", 0, options).Store()
	return
}

// GetDevice gets org.freedesktop.UDisks2.Block.Device property.
func (o *Block) GetDevice(ctx context.Context) (device []byte, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceBlock, "Device").Store(&device)
	return
}

// GetPreferredDevice gets org.freedesktop.UDisks2.Block.PreferredDevice property.
func (o *Block) GetPreferredDevice(ctx context.Context) (preferredDevice []byte, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceBlock, "PreferredDevice").Store(&preferredDevice)
	return
}

// GetSymlinks gets org.freedesktop.UDisks2.Block.Symlinks property.
func (o *Block) GetSymlinks(ctx context.Context) (symlinks [][]byte, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceBlock, "Symlinks").Store(&symlinks)
	return
}

// GetDeviceNumber gets org.freedesktop.UDisks2.Block.DeviceNumber property.
func (o *Block) GetDeviceNumber(ctx context.Context) (deviceNumber uint64, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceBlock, "DeviceNumber").Store(&deviceNumber)
	return
}

// GetId gets org.freedesktop.UDisks2.Block.Id property.
func (o *Block) GetId(ctx context.Context) (id string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceBlock, "Id").Store(&id)
	return
}

// GetSize gets org.freedesktop.UDisks2.Block.Size property.
func (o *Block) GetSize(ctx context.Context) (size uint64, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceBlock, "Size").Store(&size)
	return
}

// GetReadOnly gets org.freedesktop.UDisks2.Block.ReadOnly property.
func (o *Block) GetReadOnly(ctx context.Context) (readOnly bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceBlock, "ReadOnly").Store(&readOnly)
	return
}

// GetDrive gets org.freedesktop.UDisks2.Block.Drive property.
func (o *Block) GetDrive(ctx context.Context) (drive dbus.ObjectPath, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceBlock, "Drive").Store(&drive)
	return
}

// GetMDRaid gets org.freedesktop.UDisks2.Block.MDRaid property.
func (o *Block) GetMDRaid(ctx context.Context) (mDRaid dbus.ObjectPath, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceBlock, "MDRaid").Store(&mDRaid)
	return
}

// GetMDRaidMember gets org.freedesktop.UDisks2.Block.MDRaidMember property.
func (o *Block) GetMDRaidMember(ctx context.Context) (mDRaidMember dbus.ObjectPath, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceBlock, "MDRaidMember").Store(&mDRaidMember)
	return
}

// GetIdUsage gets org.freedesktop.UDisks2.Block.IdUsage property.
func (o *Block) GetIdUsage(ctx context.Context) (idUsage string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceBlock, "IdUsage").Store(&idUsage)
	return
}

// GetIdType gets org.freedesktop.UDisks2.Block.IdType property.
func (o *Block) GetIdType(ctx context.Context) (idType string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceBlock, "IdType").Store(&idType)
	return
}

// GetIdVersion gets org.freedesktop.UDisks2.Block.IdVersion property.
func (o *Block) GetIdVersion(ctx context.Context) (idVersion string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceBlock, "IdVersion").Store(&idVersion)
	return
}

// GetIdLabel gets org.freedesktop.UDisks2.Block.IdLabel property.
func (o *Block) GetIdLabel(ctx context.Context) (idLabel string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceBlock, "IdLabel").Store(&idLabel)
	return
}

// GetIdUUID gets org.freedesktop.UDisks2.Block.IdUUID property.
func (o *Block) GetIdUUID(ctx context.Context) (idUUID string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceBlock, "IdUUID").Store(&idUUID)
	return
}

// GetConfiguration gets org.freedesktop.UDisks2.Block.Configuration property.
func (o *Block) GetConfiguration(ctx context.Context) (configuration []struct {
	V0 string
	V1 map[string]dbus.Variant
}, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceBlock, "Configuration").Store(&configuration)
	return
}

// GetCryptoBackingDevice gets org.freedesktop.UDisks2.Block.CryptoBackingDevice property.
func (o *Block) GetCryptoBackingDevice(ctx context.Context) (cryptoBackingDevice dbus.ObjectPath, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceBlock, "CryptoBackingDevice").Store(&cryptoBackingDevice)
	return
}

// GetHintPartitionable gets org.freedesktop.UDisks2.Block.HintPartitionable property.
func (o *Block) GetHintPartitionable(ctx context.Context) (hintPartitionable bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceBlock, "HintPartitionable").Store(&hintPartitionable)
	return
}

// GetHintSystem gets org.freedesktop.UDisks2.Block.HintSystem property.
func (o *Block) GetHintSystem(ctx context.Context) (hintSystem bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceBlock, "HintSystem").Store(&hintSystem)
	return
}

// GetHintIgnore gets org.freedesktop.UDisks2.Block.HintIgnore property.
func (o *Block) GetHintIgnore(ctx context.Context) (hintIgnore bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceBlock, "HintIgnore").Store(&hintIgnore)
	return
}

// GetHintAuto gets org.freedesktop.UDisks2.Block.HintAuto property.
func (o *Block) GetHintAuto(ctx context.Context) (hintAuto bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceBlock, "HintAuto").Store(&hintAuto)
	return
}

// GetHintName gets org.freedesktop.UDisks2.Block.HintName property.
func (o *Block) GetHintName(ctx context.Context) (hintName string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceBlock, "HintName").Store(&hintName)
	return
}

// GetHintIconName gets org.freedesktop.UDisks2.Block.HintIconName property.
func (o *Block) GetHintIconName(ctx context.Context) (hintIconName string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceBlock, "HintIconName").Store(&hintIconName)
	return
}

// GetHintSymbolicIconName gets org.freedesktop.UDisks2.Block.HintSymbolicIconName property.
func (o *Block) GetHintSymbolicIconName(ctx context.Context) (hintSymbolicIconName string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceBlock, "HintSymbolicIconName").Store(&hintSymbolicIconName)
	return
}

// GetUserspaceMountOptions gets org.freedesktop.UDisks2.Block.UserspaceMountOptions property.
func (o *Block) GetUserspaceMountOptions(ctx context.Context) (userspaceMountOptions []string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceBlock, "UserspaceMountOptions").Store(&userspaceMountOptions)
	return
}

// NewPartitionTable creates and allocates org.freedesktop.UDisks2.PartitionTable.
func NewPartitionTable(object dbus.BusObject) *PartitionTable {
	return &PartitionTable{object}
}

// PartitionTable implements org.freedesktop.UDisks2.PartitionTable D-Bus interface.
type PartitionTable struct {
	object dbus.BusObject
}

// CreatePartition calls org.freedesktop.UDisks2.PartitionTable.CreatePartition method.
func (o *PartitionTable) CreatePartition(ctx context.Context, offset uint64, size uint64, inType string, name string, options map[string]dbus.Variant) (createdPartition dbus.ObjectPath, err error) {
	err = o.object.CallWithContext(ctx, InterfacePartitionTable+".CreatePartition", 0, offset, size, inType, name, options).Store(&createdPartition)
	return
}

// CreatePartitionAndFormat calls org.freedesktop.UDisks2.PartitionTable.CreatePartitionAndFormat method.
func (o *PartitionTable) CreatePartitionAndFormat(ctx context.Context, offset uint64, size uint64, inType string, name string, options map[string]dbus.Variant, formatType string, formatOptions map[string]dbus.Variant) (createdPartition dbus.ObjectPath, err error) {
	err = o.object.CallWithContext(ctx, InterfacePartitionTable+".CreatePartitionAndFormat", 0, offset, size, inType, name, options, formatType, formatOptions).Store(&createdPartition)
	return
}

// GetPartitions gets org.freedesktop.UDisks2.PartitionTable.Partitions property.
func (o *PartitionTable) GetPartitions(ctx context.Context) (partitions []dbus.ObjectPath, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfacePartitionTable, "Partitions").Store(&partitions)
	return
}

// GetType gets org.freedesktop.UDisks2.PartitionTable.Type property.
func (o *PartitionTable) GetType(ctx context.Context) (vType string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfacePartitionTable, "Type").Store(&vType)
	return
}

// NewPartition creates and allocates org.freedesktop.UDisks2.Partition.
func NewPartition(object dbus.BusObject) *Partition {
	return &Partition{object}
}

// Partition implements org.freedesktop.UDisks2.Partition D-Bus interface.
type Partition struct {
	object dbus.BusObject
}

// SetType calls org.freedesktop.UDisks2.Partition.SetType method.
func (o *Partition) SetType(ctx context.Context, inType string, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfacePartition+".SetType", 0, inType, options).Store()
	return
}

// SetName calls org.freedesktop.UDisks2.Partition.SetName method.
func (o *Partition) SetName(ctx context.Context, name string, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfacePartition+".SetName", 0, name, options).Store()
	return
}

// SetFlags calls org.freedesktop.UDisks2.Partition.SetFlags method.
func (o *Partition) SetFlags(ctx context.Context, flags uint64, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfacePartition+".SetFlags", 0, flags, options).Store()
	return
}

// Resize calls org.freedesktop.UDisks2.Partition.Resize method.
func (o *Partition) Resize(ctx context.Context, size uint64, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfacePartition+".Resize", 0, size, options).Store()
	return
}

// Delete calls org.freedesktop.UDisks2.Partition.Delete method.
func (o *Partition) Delete(ctx context.Context, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfacePartition+".Delete", 0, options).Store()
	return
}

// GetNumber gets org.freedesktop.UDisks2.Partition.Number property.
func (o *Partition) GetNumber(ctx context.Context) (number uint32, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfacePartition, "Number").Store(&number)
	return
}

// GetType gets org.freedesktop.UDisks2.Partition.Type property.
func (o *Partition) GetType(ctx context.Context) (vType string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfacePartition, "Type").Store(&vType)
	return
}

// GetFlags gets org.freedesktop.UDisks2.Partition.Flags property.
func (o *Partition) GetFlags(ctx context.Context) (flags uint64, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfacePartition, "Flags").Store(&flags)
	return
}

// GetOffset gets org.freedesktop.UDisks2.Partition.Offset property.
func (o *Partition) GetOffset(ctx context.Context) (offset uint64, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfacePartition, "Offset").Store(&offset)
	return
}

// GetSize gets org.freedesktop.UDisks2.Partition.Size property.
func (o *Partition) GetSize(ctx context.Context) (size uint64, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfacePartition, "Size").Store(&size)
	return
}

// GetName gets org.freedesktop.UDisks2.Partition.Name property.
func (o *Partition) GetName(ctx context.Context) (name string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfacePartition, "Name").Store(&name)
	return
}

// GetUUID gets org.freedesktop.UDisks2.Partition.UUID property.
func (o *Partition) GetUUID(ctx context.Context) (uUID string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfacePartition, "UUID").Store(&uUID)
	return
}

// GetTable gets org.freedesktop.UDisks2.Partition.Table property.
func (o *Partition) GetTable(ctx context.Context) (table dbus.ObjectPath, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfacePartition, "Table").Store(&table)
	return
}

// GetIsContainer gets org.freedesktop.UDisks2.Partition.IsContainer property.
func (o *Partition) GetIsContainer(ctx context.Context) (isContainer bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfacePartition, "IsContainer").Store(&isContainer)
	return
}

// GetIsContained gets org.freedesktop.UDisks2.Partition.IsContained property.
func (o *Partition) GetIsContained(ctx context.Context) (isContained bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfacePartition, "IsContained").Store(&isContained)
	return
}

// NewFilesystem creates and allocates org.freedesktop.UDisks2.Filesystem.
func NewFilesystem(object dbus.BusObject) *Filesystem {
	return &Filesystem{object}
}

// Filesystem implements org.freedesktop.UDisks2.Filesystem D-Bus interface.
type Filesystem struct {
	object dbus.BusObject
}

// SetLabel calls org.freedesktop.UDisks2.Filesystem.SetLabel method.
func (o *Filesystem) SetLabel(ctx context.Context, label string, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceFilesystem+".SetLabel", 0, label, options).Store()
	return
}

// Mount calls org.freedesktop.UDisks2.Filesystem.Mount method.
func (o *Filesystem) Mount(ctx context.Context, options map[string]dbus.Variant) (mountPath string, err error) {
	err = o.object.CallWithContext(ctx, InterfaceFilesystem+".Mount", 0, options).Store(&mountPath)
	return
}

// Unmount calls org.freedesktop.UDisks2.Filesystem.Unmount method.
func (o *Filesystem) Unmount(ctx context.Context, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceFilesystem+".Unmount", 0, options).Store()
	return
}

// Resize calls org.freedesktop.UDisks2.Filesystem.Resize method.
func (o *Filesystem) Resize(ctx context.Context, size uint64, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceFilesystem+".Resize", 0, size, options).Store()
	return
}

// Check calls org.freedesktop.UDisks2.Filesystem.Check method.
func (o *Filesystem) Check(ctx context.Context, options map[string]dbus.Variant) (consistent bool, err error) {
	err = o.object.CallWithContext(ctx, InterfaceFilesystem+".Check", 0, options).Store(&consistent)
	return
}

// Repair calls org.freedesktop.UDisks2.Filesystem.Repair method.
func (o *Filesystem) Repair(ctx context.Context, options map[string]dbus.Variant) (repaired bool, err error) {
	err = o.object.CallWithContext(ctx, InterfaceFilesystem+".Repair", 0, options).Store(&repaired)
	return
}

// TakeOwnership calls org.freedesktop.UDisks2.Filesystem.TakeOwnership method.
func (o *Filesystem) TakeOwnership(ctx context.Context, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceFilesystem+".TakeOwnership", 0, options).Store()
	return
}

// GetMountPoints gets org.freedesktop.UDisks2.Filesystem.MountPoints property.
func (o *Filesystem) GetMountPoints(ctx context.Context) (mountPoints [][]byte, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceFilesystem, "MountPoints").Store(&mountPoints)
	return
}

// GetSize gets org.freedesktop.UDisks2.Filesystem.Size property.
func (o *Filesystem) GetSize(ctx context.Context) (size uint64, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceFilesystem, "Size").Store(&size)
	return
}

// NewSwapspace creates and allocates org.freedesktop.UDisks2.Swapspace.
func NewSwapspace(object dbus.BusObject) *Swapspace {
	return &Swapspace{object}
}

// Swapspace implements org.freedesktop.UDisks2.Swapspace D-Bus interface.
type Swapspace struct {
	object dbus.BusObject
}

// Start calls org.freedesktop.UDisks2.Swapspace.Start method.
func (o *Swapspace) Start(ctx context.Context, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceSwapspace+".Start", 0, options).Store()
	return
}

// Stop calls org.freedesktop.UDisks2.Swapspace.Stop method.
func (o *Swapspace) Stop(ctx context.Context, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceSwapspace+".Stop", 0, options).Store()
	return
}

// SetLabel calls org.freedesktop.UDisks2.Swapspace.SetLabel method.
func (o *Swapspace) SetLabel(ctx context.Context, label string, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceSwapspace+".SetLabel", 0, label, options).Store()
	return
}

// GetActive gets org.freedesktop.UDisks2.Swapspace.Active property.
func (o *Swapspace) GetActive(ctx context.Context) (active bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceSwapspace, "Active").Store(&active)
	return
}

// NewEncrypted creates and allocates org.freedesktop.UDisks2.Encrypted.
func NewEncrypted(object dbus.BusObject) *Encrypted {
	return &Encrypted{object}
}

// Encrypted implements org.freedesktop.UDisks2.Encrypted D-Bus interface.
type Encrypted struct {
	object dbus.BusObject
}

// Unlock calls org.freedesktop.UDisks2.Encrypted.Unlock method.
func (o *Encrypted) Unlock(ctx context.Context, passphrase string, options map[string]dbus.Variant) (cleartextDevice dbus.ObjectPath, err error) {
	err = o.object.CallWithContext(ctx, InterfaceEncrypted+".Unlock", 0, passphrase, options).Store(&cleartextDevice)
	return
}

// Lock calls org.freedesktop.UDisks2.Encrypted.Lock method.
func (o *Encrypted) Lock(ctx context.Context, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceEncrypted+".Lock", 0, options).Store()
	return
}

// ChangePassphrase calls org.freedesktop.UDisks2.Encrypted.ChangePassphrase method.
func (o *Encrypted) ChangePassphrase(ctx context.Context, passphrase string, newPassphrase string, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceEncrypted+".ChangePassphrase", 0, passphrase, newPassphrase, options).Store()
	return
}

// Resize calls org.freedesktop.UDisks2.Encrypted.Resize method.
func (o *Encrypted) Resize(ctx context.Context, size uint64, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceEncrypted+".Resize", 0, size, options).Store()
	return
}

// GetChildConfiguration gets org.freedesktop.UDisks2.Encrypted.ChildConfiguration property.
func (o *Encrypted) GetChildConfiguration(ctx context.Context) (childConfiguration []struct {
	V0 string
	V1 map[string]dbus.Variant
}, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceEncrypted, "ChildConfiguration").Store(&childConfiguration)
	return
}

// GetHintEncryptionType gets org.freedesktop.UDisks2.Encrypted.HintEncryptionType property.
func (o *Encrypted) GetHintEncryptionType(ctx context.Context) (hintEncryptionType string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceEncrypted, "HintEncryptionType").Store(&hintEncryptionType)
	return
}

// GetMetadataSize gets org.freedesktop.UDisks2.Encrypted.MetadataSize property.
func (o *Encrypted) GetMetadataSize(ctx context.Context) (metadataSize uint64, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceEncrypted, "MetadataSize").Store(&metadataSize)
	return
}

// GetCleartextDevice gets org.freedesktop.UDisks2.Encrypted.CleartextDevice property.
func (o *Encrypted) GetCleartextDevice(ctx context.Context) (cleartextDevice dbus.ObjectPath, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceEncrypted, "CleartextDevice").Store(&cleartextDevice)
	return
}

// NewLoop creates and allocates org.freedesktop.UDisks2.Loop.
func NewLoop(object dbus.BusObject) *Loop {
	return &Loop{object}
}

// Loop implements org.freedesktop.UDisks2.Loop D-Bus interface.
type Loop struct {
	object dbus.BusObject
}

// Delete calls org.freedesktop.UDisks2.Loop.Delete method.
func (o *Loop) Delete(ctx context.Context, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceLoop+".Delete", 0, options).Store()
	return
}

// SetAutoclear calls org.freedesktop.UDisks2.Loop.SetAutoclear method.
func (o *Loop) SetAutoclear(ctx context.Context, value bool, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceLoop+".SetAutoclear", 0, value, options).Store()
	return
}

// GetBackingFile gets org.freedesktop.UDisks2.Loop.BackingFile property.
func (o *Loop) GetBackingFile(ctx context.Context) (backingFile []byte, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceLoop, "BackingFile").Store(&backingFile)
	return
}

// GetAutoclear gets org.freedesktop.UDisks2.Loop.Autoclear property.
func (o *Loop) GetAutoclear(ctx context.Context) (autoclear bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceLoop, "Autoclear").Store(&autoclear)
	return
}

// GetSetupByUID gets org.freedesktop.UDisks2.Loop.SetupByUID property.
func (o *Loop) GetSetupByUID(ctx context.Context) (setupByUID uint32, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceLoop, "SetupByUID").Store(&setupByUID)
	return
}

// NewMDRaid creates and allocates org.freedesktop.UDisks2.MDRaid.
func NewMDRaid(object dbus.BusObject) *MDRaid {
	return &MDRaid{object}
}

// MDRaid implements org.freedesktop.UDisks2.MDRaid D-Bus interface.
type MDRaid struct {
	object dbus.BusObject
}

// Start calls org.freedesktop.UDisks2.MDRaid.Start method.
func (o *MDRaid) Start(ctx context.Context, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceMDRaid+".Start", 0, options).Store()
	return
}

// Stop calls org.freedesktop.UDisks2.MDRaid.Stop method.
func (o *MDRaid) Stop(ctx context.Context, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceMDRaid+".Stop", 0, options).Store()
	return
}

// RemoveDevice calls org.freedesktop.UDisks2.MDRaid.RemoveDevice method.
func (o *MDRaid) RemoveDevice(ctx context.Context, device dbus.ObjectPath, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceMDRaid+".RemoveDevice", 0, device, options).Store()
	return
}

// AddDevice calls org.freedesktop.UDisks2.MDRaid.AddDevice method.
func (o *MDRaid) AddDevice(ctx context.Context, device dbus.ObjectPath, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceMDRaid+".AddDevice", 0, device, options).Store()
	return
}

// SetBitmapLocation calls org.freedesktop.UDisks2.MDRaid.SetBitmapLocation method.
func (o *MDRaid) SetBitmapLocation(ctx context.Context, value []byte, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceMDRaid+".SetBitmapLocation", 0, value, options).Store()
	return
}

// RequestSyncAction calls org.freedesktop.UDisks2.MDRaid.RequestSyncAction method.
func (o *MDRaid) RequestSyncAction(ctx context.Context, syncAction string, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceMDRaid+".RequestSyncAction", 0, syncAction, options).Store()
	return
}

// Delete calls org.freedesktop.UDisks2.MDRaid.Delete method.
func (o *MDRaid) Delete(ctx context.Context, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceMDRaid+".Delete", 0, options).Store()
	return
}

// GetUUID gets org.freedesktop.UDisks2.MDRaid.UUID property.
func (o *MDRaid) GetUUID(ctx context.Context) (uUID string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceMDRaid, "UUID").Store(&uUID)
	return
}

// GetName gets org.freedesktop.UDisks2.MDRaid.Name property.
func (o *MDRaid) GetName(ctx context.Context) (name string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceMDRaid, "Name").Store(&name)
	return
}

// GetLevel gets org.freedesktop.UDisks2.MDRaid.Level property.
func (o *MDRaid) GetLevel(ctx context.Context) (level string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceMDRaid, "Level").Store(&level)
	return
}

// GetNumDevices gets org.freedesktop.UDisks2.MDRaid.NumDevices property.
func (o *MDRaid) GetNumDevices(ctx context.Context) (numDevices uint32, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceMDRaid, "NumDevices").Store(&numDevices)
	return
}

// GetSize gets org.freedesktop.UDisks2.MDRaid.Size property.
func (o *MDRaid) GetSize(ctx context.Context) (size uint64, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceMDRaid, "Size").Store(&size)
	return
}

// GetSyncAction gets org.freedesktop.UDisks2.MDRaid.SyncAction property.
func (o *MDRaid) GetSyncAction(ctx context.Context) (syncAction string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceMDRaid, "SyncAction").Store(&syncAction)
	return
}

// GetSyncCompleted gets org.freedesktop.UDisks2.MDRaid.SyncCompleted property.
func (o *MDRaid) GetSyncCompleted(ctx context.Context) (syncCompleted float64, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceMDRaid, "SyncCompleted").Store(&syncCompleted)
	return
}

// GetSyncRate gets org.freedesktop.UDisks2.MDRaid.SyncRate property.
func (o *MDRaid) GetSyncRate(ctx context.Context) (syncRate uint64, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceMDRaid, "SyncRate").Store(&syncRate)
	return
}

// GetSyncRemainingTime gets org.freedesktop.UDisks2.MDRaid.SyncRemainingTime property.
func (o *MDRaid) GetSyncRemainingTime(ctx context.Context) (syncRemainingTime uint64, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceMDRaid, "SyncRemainingTime").Store(&syncRemainingTime)
	return
}

// GetDegraded gets org.freedesktop.UDisks2.MDRaid.Degraded property.
func (o *MDRaid) GetDegraded(ctx context.Context) (degraded uint32, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceMDRaid, "Degraded").Store(&degraded)
	return
}

// GetBitmapLocation gets org.freedesktop.UDisks2.MDRaid.BitmapLocation property.
func (o *MDRaid) GetBitmapLocation(ctx context.Context) (bitmapLocation []byte, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceMDRaid, "BitmapLocation").Store(&bitmapLocation)
	return
}

// GetChunkSize gets org.freedesktop.UDisks2.MDRaid.ChunkSize property.
func (o *MDRaid) GetChunkSize(ctx context.Context) (chunkSize uint64, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceMDRaid, "ChunkSize").Store(&chunkSize)
	return
}

// GetActiveDevices gets org.freedesktop.UDisks2.MDRaid.ActiveDevices property.
func (o *MDRaid) GetActiveDevices(ctx context.Context) (activeDevices []struct {
	V0 dbus.ObjectPath
	V1 int32
	V2 []string
	V3 uint64
	V4 map[string]dbus.Variant
}, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceMDRaid, "ActiveDevices").Store(&activeDevices)
	return
}

// GetChildConfiguration gets org.freedesktop.UDisks2.MDRaid.ChildConfiguration property.
func (o *MDRaid) GetChildConfiguration(ctx context.Context) (childConfiguration []struct {
	V0 string
	V1 map[string]dbus.Variant
}, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceMDRaid, "ChildConfiguration").Store(&childConfiguration)
	return
}

// GetRunning gets org.freedesktop.UDisks2.MDRaid.Running property.
func (o *MDRaid) GetRunning(ctx context.Context) (running bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceMDRaid, "Running").Store(&running)
	return
}

// NewJob creates and allocates org.freedesktop.UDisks2.Job.
func NewJob(object dbus.BusObject) *Job {
	return &Job{object}
}

// Job implements org.freedesktop.UDisks2.Job D-Bus interface.
type Job struct {
	object dbus.BusObject
}

// Cancel calls org.freedesktop.UDisks2.Job.Cancel method.
func (o *Job) Cancel(ctx context.Context, options map[string]dbus.Variant) (err error) {
	err = o.object.CallWithContext(ctx, InterfaceJob+".Cancel", 0, options).Store()
	return
}

// GetOperation gets org.freedesktop.UDisks2.Job.Operation property.
func (o *Job) GetOperation(ctx context.Context) (operation string, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceJob, "Operation").Store(&operation)
	return
}

// GetProgress gets org.freedesktop.UDisks2.Job.Progress property.
func (o *Job) GetProgress(ctx context.Context) (progress float64, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceJob, "Progress").Store(&progress)
	return
}

// GetProgressValid gets org.freedesktop.UDisks2.Job.ProgressValid property.
func (o *Job) GetProgressValid(ctx context.Context) (progressValid bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceJob, "ProgressValid").Store(&progressValid)
	return
}

// GetBytes gets org.freedesktop.UDisks2.Job.Bytes property.
func (o *Job) GetBytes(ctx context.Context) (bytes uint64, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceJob, "Bytes").Store(&bytes)
	return
}

// GetRate gets org.freedesktop.UDisks2.Job.Rate property.
func (o *Job) GetRate(ctx context.Context) (rate uint64, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceJob, "Rate").Store(&rate)
	return
}

// GetStartTime gets org.freedesktop.UDisks2.Job.StartTime property.
func (o *Job) GetStartTime(ctx context.Context) (startTime uint64, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceJob, "StartTime").Store(&startTime)
	return
}

// GetExpectedEndTime gets org.freedesktop.UDisks2.Job.ExpectedEndTime property.
func (o *Job) GetExpectedEndTime(ctx context.Context) (expectedEndTime uint64, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceJob, "ExpectedEndTime").Store(&expectedEndTime)
	return
}

// GetObjects gets org.freedesktop.UDisks2.Job.Objects property.
func (o *Job) GetObjects(ctx context.Context) (objects []dbus.ObjectPath, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceJob, "Objects").Store(&objects)
	return
}

// GetStartedByUID gets org.freedesktop.UDisks2.Job.StartedByUID property.
func (o *Job) GetStartedByUID(ctx context.Context) (startedByUID uint32, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceJob, "StartedByUID").Store(&startedByUID)
	return
}

// GetCancelable gets org.freedesktop.UDisks2.Job.Cancelable property.
func (o *Job) GetCancelable(ctx context.Context) (cancelable bool, err error) {
	err = o.object.CallWithContext(ctx, "org.freedesktop.DBus.Properties.Get", 0, InterfaceJob, "Cancelable").Store(&cancelable)
	return
}

// JobCompletedSignal represents org.freedesktop.UDisks2.Job.Completed signal.
type JobCompletedSignal struct {
	sender string
	Path   dbus.ObjectPath
	Body   *JobCompletedSignalBody
}

// Name returns the signal's name.
func (s *JobCompletedSignal) Name() string {
	return "Completed"
}

// Interface returns the signal's interface.
func (s *JobCompletedSignal) Interface() string {
	return InterfaceJob
}

// Sender returns the signal's sender unique name.
func (s *JobCompletedSignal) Sender() string {
	return s.sender
}

func (s *JobCompletedSignal) path() dbus.ObjectPath {
	return s.Path
}

func (s *JobCompletedSignal) values() []interface{} {
	return []interface{}{s.Body.Success, s.Body.Message}
}

// JobCompletedSignalBody is body container.
type JobCompletedSignalBody struct {
	Success bool
	Message string
}
0707010000002E000081A400000000000000000000000164F6FC38000004CF000000000000000000000000000000000000003100000000homeassistant-os-agent-1.6.0/udisks2/apiutils.gopackage udisks2

import (
	"context"
	"fmt"
	"strings"

"github.com/godbus/dbus/v5"
)

var noOptions = map[string]dbus.Variant{}

func (o *Block) GetDeviceString(ctx context.Context) (*string, error) {

device, err := o.GetDevice(ctx)
	if err != nil {
		return nil, err
	}

s := strings.Trim(string(device), "\x00")
	return &s, nil
}

func (f *Filesystem) GetMountPointsString(ctx context.Context) ([]string, error) {
	dataMountPoints, err := f.GetMountPoints(ctx)
	if err != nil {
		return nil, err
	}

dataMountPointsString := make([]string, len(dataMountPoints))
	for i, ba := range dataMountPoints {
		s := strings.Trim(string(ba), "\x00")
		dataMountPointsString[i] = s
	}

return dataMountPointsString, nil
}

func (m *Manager) ResolveDeviceFromLabel(label string) (*dbus.ObjectPath, error) {
	devspec := map[string]dbus.Variant{"label": dbus.MakeVariant(label)}
	blockObjects, err := m.ResolveDevice(context.Background(), devspec, noOptions)

if err != nil {
		return nil, err
	}
	if len(blockObjects) != 1 {
		return nil, fmt.Errorf("Expected single block device with file system label \"%s\", found %d", label, len(blockObjects))
	}

/* Get Partition object of the data partition */
	return &blockObjects[0], nil
}
0707010000002F000081A400000000000000000000000164F6FC3800000E05000000000000000000000000000000000000002F00000000homeassistant-os-agent-1.6.0/udisks2/helper.gopackage udisks2

import (
	"context"
	"fmt"

"github.com/godbus/dbus/v5"

logging "github.com/home-assistant/os-agent/utils/log"
)

type UDisks2Helper struct {
	conn    *dbus.Conn
	manager *Manager
}

func NewUDisks2(conn *dbus.Conn) UDisks2Helper {
	busObj := conn.Object("org.freedesktop.UDisks2", "/org/freedesktop/UDisks2/Manager")
	manager := NewManager(busObj)

d := UDisks2Helper{
		conn:    conn,
		manager: manager,
	}

return d
}

func (u UDisks2Helper) GetBusObjectFromLabel(label string) (dbus.BusObject, error) {

busObject, err := u.manager.ResolveDeviceFromLabel(label)
	if err != nil {
		return nil, err
	}

return u.conn.Object("org.freedesktop.UDisks2", *busObject), nil
}

func (u UDisks2Helper) GetRootDeviceFromLabel(label string) (*string, error) {

busObject, err := u.manager.ResolveDeviceFromLabel(label)
	if err != nil {
		return nil, err
	}

busObjectBlock := u.conn.Object("org.freedesktop.UDisks2", *busObject)
	partition := NewPartition(busObjectBlock)
	table, err := partition.GetTable(context.Background())
	if err != nil {
		return nil, err
	}

/* Get Block device of partition table */
	busObjectParentBlock := u.conn.Object("org.freedesktop.UDisks2", table)
	parentBlock := NewBlock(busObjectParentBlock)

return parentBlock.GetDeviceString(context.Background())
}

func (u UDisks2Helper) FormatPartition(blockObjectPath dbus.BusObject, fsType string, label string) error {
	parentBlock := NewBlock(blockObjectPath)
	formatOptions := map[string]dbus.Variant{"label": dbus.MakeVariant(label)}
	err := parentBlock.Format(context.Background(), fsType, formatOptions)
	if err != nil {
		return err
	}

return nil
}

func (u UDisks2Helper) FormatPartitionFromDevicePath(devicePath string, fsType string, label string) error {
	devspec := map[string]dbus.Variant{"path": dbus.MakeVariant(devicePath)}
	blockObjects, err := u.manager.ResolveDevice(context.Background(), devspec, noOptions)
	if err != nil {
		return err
	}
	if len(blockObjects) != 1 {
		return fmt.Errorf("Expected single block device with device path \"%s\", found %d", devicePath, len(blockObjects))
	}

logging.Info.Printf("Formatting block device %s with file system \"%s\".", devicePath, fsType)
	blockObjectPath := blockObjects[0]
	busObjectBlock := u.conn.Object("org.freedesktop.UDisks2", blockObjectPath)

err = u.FormatPartition(busObjectBlock, fsType, label)
	if err != nil {
		return err
	}

logging.Info.Printf("Successfully formatted block device %s.", devicePath)

return nil
}

func (u UDisks2Helper) PartitionDeviceWithSinglePartition(devicePath string, uuid string, name string) error {
	devspec := map[string]dbus.Variant{"path": dbus.MakeVariant(devicePath)}
	blockObjects, err := u.manager.ResolveDevice(context.Background(), devspec, noOptions)
	if err != nil {
		return err
	}
	if len(blockObjects) != 1 {
		return fmt.Errorf("Expected single block device with device path \"%s\", found %d", devicePath, len(blockObjects))
	}

blockObjectPath := blockObjects[0]
	logging.Info.Printf("Formatting device %s", devicePath)

busObjectParentBlock := u.conn.Object("org.freedesktop.UDisks2", blockObjectPath)
	parentBlock := NewBlock(busObjectParentBlock)
	err = parentBlock.Format(context.Background(), "gpt", noOptions)
	if err != nil {
		return err
	}

parentPartitionTable := NewPartitionTable(busObjectParentBlock)
	createdPartition, err :=
		parentPartitionTable.CreatePartition(context.Background(), 0, 0,
			uuid, name, noOptions)
	if err != nil {
		return err
	}
	logging.Info.Printf("New partition D-Bus object %s.", createdPartition)

return nil
}
07070100000030000041ED00000000000000000000000264F6FC3800000000000000000000000000000000000000000000002300000000homeassistant-os-agent-1.6.0/utils07070100000031000041ED00000000000000000000000264F6FC3800000000000000000000000000000000000000000000002C00000000homeassistant-os-agent-1.6.0/utils/bootfile07070100000032000081A400000000000000000000000164F6FC3800000AC5000000000000000000000000000000000000003600000000homeassistant-os-agent-1.6.0/utils/bootfile/editor.gopackage bootfile

import (
	"bufio"
	"os"
	"strings"

logging "github.com/home-assistant/os-agent/utils/log"

"github.com/natefinch/atomic"
)

type Editor struct {
	FilePath  string
	Delimiter string
}

func (e Editor) ReadOption(optionName string, defaultValue string) (string, error) {
	// Read the options from the boot file
	file, err := os.Open(e.FilePath)
	if err != nil {
		logging.Error.Printf("Failed to open boot file %s: %s", e.FilePath, err)
		return defaultValue, err
	}
	defer file.Close()

// Scan over all lines
	fileScanner := bufio.NewScanner(file)
	fileScanner.Split(bufio.ScanLines)

for fileScanner.Scan() {
		line := fileScanner.Text()
		if strings.HasPrefix(line, optionName) {
			return strings.Replace(line, optionName+e.Delimiter, "", 1), nil
		}
	}

return defaultValue, nil
}

func (e Editor) DisableOption(optionName string) error {
	// Read the options from the boot file
	file, err := os.Open(e.FilePath)
	if err != nil {
		logging.Error.Printf("Failed to open boot file %s: %s", e.FilePath, err)
		return err
	}

// Scan over all lines
	fileScanner := bufio.NewScanner(file)
	fileScanner.Split(bufio.ScanLines)

var outLines []string
	for fileScanner.Scan() {
		line := fileScanner.Text()
		if strings.HasPrefix(line, optionName) {
			outLines = append(outLines, "#"+line)
		} else {
			outLines = append(outLines, line)
		}
	}
	file.Close()

// Write all lines back to boot config file
	return e.writeNewBootFile(outLines)
}

func (e Editor) SetOption(optionName string, value string) error {
	// Read the options from the boot file
	file, err := os.Open(e.FilePath)
	if err != nil {
		logging.Error.Printf("Failed to open boot file %s: %s", e.FilePath, err)
		return err
	}

// Scan over all lines
	fileScanner := bufio.NewScanner(file)
	fileScanner.Split(bufio.ScanLines)

var outLines []string
	var found bool = false
	for fileScanner.Scan() {
		line := fileScanner.Text()
		if strings.HasPrefix(line, optionName) || strings.HasPrefix(line, "#"+optionName) {
			if !found {
				outLines = append(outLines, optionName+e.Delimiter+value)
				found = true
			}
		} else {
			outLines = append(outLines, line)
		}
	}
	file.Close()

// No option found, add it
	if !found {
		outLines = append(outLines, optionName+e.Delimiter+value)
	}

// Write all lines back to boot config file
	return e.writeNewBootFile(outLines)
}

func (e Editor) writeNewBootFile(lines []string) error {
	// Write all lines back to boot config file
	raw := strings.Join(lines, "\n")
	if !strings.HasSuffix(raw, "\n") {
		raw += "\n"
	}
	reader := strings.NewReader(raw)

err := atomic.WriteFile(e.FilePath, reader)
	if err != nil {
		logging.Error.Printf("Failed to write boot file %s: %s", e.FilePath, err)
		return err
	}

return err
}
07070100000033000041ED00000000000000000000000264F6FC3800000000000000000000000000000000000000000000002700000000homeassistant-os-agent-1.6.0/utils/led07070100000034000081A400000000000000000000000164F6FC38000002F0000000000000000000000000000000000000002E00000000homeassistant-os-agent-1.6.0/utils/led/led.gopackage led

import (
	"os"
	"path/filepath"
	"strings"
)

type LED struct {
	Name           string
	DefaultTrigger string
}

func (led LED) GetTrigger() (string, error) {
	ledTriggerFilePath := filepath.Join("/sys/class/leds/", led.Name, "trigger")
	ledTrigger, err := os.ReadFile(ledTriggerFilePath)
	if err != nil {
		return "", err
	}
	return strings.TrimSpace(string(ledTrigger)), err
}

func (led LED) SetTrigger(newState bool) error {
	ledTriggerFilePath := filepath.Join("/sys/class/leds/", led.Name, "trigger")
	var newTrigger []byte

if newState {
		newTrigger = []byte(led.DefaultTrigger)
	} else {
		newTrigger = []byte("none")
	}

err := os.WriteFile(ledTriggerFilePath, newTrigger, 0600)
	if err != nil {
		return err
	}

return nil
}
07070100000035000041ED00000000000000000000000264F6FC3800000000000000000000000000000000000000000000002700000000homeassistant-os-agent-1.6.0/utils/log07070100000036000081A400000000000000000000000164F6FC38000001D0000000000000000000000000000000000000002E00000000homeassistant-os-agent-1.6.0/utils/log/log.gopackage logging

import (
	"log"
	"os"
)

var (
	Info     *log.Logger
	Warning  *log.Logger
	Error    *log.Logger
	Critical *log.Logger
)

func init() {

Info = log.New(os.Stdout, "INFO: ", log.Ldate|log.Ltime|log.Lshortfile)
	Warning = log.New(os.Stdout, "WARNING: ", log.Ldate|log.Ltime|log.Lshortfile)
	Error = log.New(os.Stderr, "ERROR: ", log.Ldate|log.Ltime|log.Lshortfile)
	Critical = log.New(os.Stderr, "CRITICAL: ", log.Ldate|log.Ltime|log.Lshortfile)
}
07070100000000000000000000000000000000000000010000000000000000000000000000000000000000000000000000000B00000000TRAILER!!!266 blocks

Places

File homeassistant-os-agent-1.6.0.obscpio of Package homeassistant-os-agent (Revision 519af55c388f8c77d691f87d882158e7)

Places