28 Commits

Author SHA1 Message Date
dependabot-preview[bot]
eea24e3047 Bump golang.org/x/text from 0.3.3 to 0.3.4 (#79)
Bumps [golang.org/x/text](https://github.com/golang/text) from 0.3.3 to 0.3.4.
- [Release notes](https://github.com/golang/text/releases)
- [Commits](https://github.com/golang/text/compare/v0.3.3...v0.3.4)

Signed-off-by: dependabot-preview[bot] <support@dependabot.com>

Co-authored-by: dependabot-preview[bot] <27856297+dependabot-preview[bot]@users.noreply.github.com>
2020-10-28 08:09:40 +10:00
dependabot-preview[bot]
e91312a468 Bump github.com/sirupsen/logrus from 1.6.0 to 1.7.0 (#78)
Bumps [github.com/sirupsen/logrus](https://github.com/sirupsen/logrus) from 1.6.0 to 1.7.0.
- [Release notes](https://github.com/sirupsen/logrus/releases)
- [Changelog](https://github.com/sirupsen/logrus/blob/master/CHANGELOG.md)
- [Commits](https://github.com/sirupsen/logrus/compare/v1.6.0...v1.7.0)

Signed-off-by: dependabot-preview[bot] <support@dependabot.com>

Co-authored-by: dependabot-preview[bot] <27856297+dependabot-preview[bot]@users.noreply.github.com>
2020-10-15 16:51:36 +10:00
dependabot-preview[bot]
065a93d56f Bump github.com/imdario/mergo from 0.3.9 to 0.3.11 (#77)
Bumps [github.com/imdario/mergo](https://github.com/imdario/mergo) from 0.3.9 to 0.3.11.
- [Release notes](https://github.com/imdario/mergo/releases)
- [Commits](https://github.com/imdario/mergo/compare/v0.3.9...v0.3.11)

Signed-off-by: dependabot-preview[bot] <support@dependabot.com>

Co-authored-by: dependabot-preview[bot] <27856297+dependabot-preview[bot]@users.noreply.github.com>
2020-08-13 22:49:43 +10:00
dependabot-preview[bot]
fbbf36d1a1 Bump golang.org/x/text from 0.3.2 to 0.3.3 (#74)
Bumps [golang.org/x/text](https://github.com/golang/text) from 0.3.2 to 0.3.3.
- [Release notes](https://github.com/golang/text/releases)
- [Commits](https://github.com/golang/text/compare/v0.3.2...v0.3.3)

Signed-off-by: dependabot-preview[bot] <support@dependabot.com>

Co-authored-by: dependabot-preview[bot] <27856297+dependabot-preview[bot]@users.noreply.github.com>
2020-06-17 14:40:05 +10:00
James Mills
3675251706 Refactored user flag/modes and fixed several data race bugs 2020-06-08 14:40:22 +10:00
James Mills
6f61b673a1 Refactor client 2020-06-08 14:20:21 +10:00
James Mills
4566b2021f Tidied up unused dependencies 2020-06-08 13:56:51 +10:00
James Mills
e7c5b96a6a Updated depednenices 2020-06-08 13:56:36 +10:00
James Mills
b18403ea71 Migrate to Github Actions Workflows 2020-06-08 13:47:06 +10:00
dependabot-preview[bot]
c9cbab6769 Bump github.com/stretchr/testify from 1.5.1 to 1.6.0 (#72)
Bumps [github.com/stretchr/testify](https://github.com/stretchr/testify) from 1.5.1 to 1.6.0.
- [Release notes](https://github.com/stretchr/testify/releases)
- [Commits](https://github.com/stretchr/testify/compare/v1.5.1...v1.6.0)

Signed-off-by: dependabot-preview[bot] <support@dependabot.com>

Co-authored-by: dependabot-preview[bot] <27856297+dependabot-preview[bot]@users.noreply.github.com>
2020-06-01 11:21:26 +10:00
dependabot-preview[bot]
176aba3c99 Bump gopkg.in/yaml.v2 from 2.2.8 to 2.3.0 (#68)
Bumps [gopkg.in/yaml.v2](https://github.com/go-yaml/yaml) from 2.2.8 to 2.3.0.
- [Release notes](https://github.com/go-yaml/yaml/releases)
- [Commits](https://github.com/go-yaml/yaml/compare/v2.2.8...v2.3.0)

Signed-off-by: dependabot-preview[bot] <support@dependabot.com>

Co-authored-by: dependabot-preview[bot] <27856297+dependabot-preview[bot]@users.noreply.github.com>
2020-05-13 11:45:36 +10:00
dependabot-preview[bot]
d814c48dce Bump github.com/stretchr/testify from 1.3.0 to 1.5.1 (#67)
Bumps [github.com/stretchr/testify](https://github.com/stretchr/testify) from 1.3.0 to 1.5.1.
- [Release notes](https://github.com/stretchr/testify/releases)
- [Commits](https://github.com/stretchr/testify/compare/v1.3.0...v1.5.1)

Signed-off-by: dependabot-preview[bot] <support@dependabot.com>

Co-authored-by: dependabot-preview[bot] <27856297+dependabot-preview[bot]@users.noreply.github.com>
2020-05-06 11:56:10 +10:00
dependabot-preview[bot]
3af82e3e8e Bump golang.org/x/text from 0.3.0 to 0.3.2 (#56)
Bumps [golang.org/x/text](https://github.com/golang/text) from 0.3.0 to 0.3.2.
- [Release notes](https://github.com/golang/text/releases)
- [Commits](https://github.com/golang/text/compare/v0.3.0...v0.3.2)

Signed-off-by: dependabot-preview[bot] <support@dependabot.com>

Co-authored-by: dependabot-preview[bot] <27856297+dependabot-preview[bot]@users.noreply.github.com>
Co-authored-by: James Mills <prologic@shortcircuit.net.au>
2020-05-05 15:10:46 +10:00
dependabot-preview[bot]
8a8d7b1e97 Bump github.com/prometheus/client_golang from 0.9.2 to 0.9.4 (#58)
Bumps [github.com/prometheus/client_golang](https://github.com/prometheus/client_golang) from 0.9.2 to 0.9.4.
- [Release notes](https://github.com/prometheus/client_golang/releases)
- [Changelog](https://github.com/prometheus/client_golang/blob/master/CHANGELOG.md)
- [Commits](https://github.com/prometheus/client_golang/compare/v0.9.2...v0.9.4)

Signed-off-by: dependabot-preview[bot] <support@dependabot.com>

Co-authored-by: dependabot-preview[bot] <27856297+dependabot-preview[bot]@users.noreply.github.com>
Co-authored-by: James Mills <prologic@shortcircuit.net.au>
2020-05-05 15:09:36 +10:00
dependabot-preview[bot]
2ac33b7d2c Bump gopkg.in/yaml.v2 from 2.2.2 to 2.2.8 (#60)
Bumps [gopkg.in/yaml.v2](https://github.com/go-yaml/yaml) from 2.2.2 to 2.2.8.
- [Release notes](https://github.com/go-yaml/yaml/releases)
- [Commits](https://github.com/go-yaml/yaml/compare/v2.2.2...v2.2.8)

Signed-off-by: dependabot-preview[bot] <support@dependabot.com>

Co-authored-by: dependabot-preview[bot] <27856297+dependabot-preview[bot]@users.noreply.github.com>
Co-authored-by: James Mills <prologic@shortcircuit.net.au>
2020-05-05 15:08:30 +10:00
dependabot-preview[bot]
a54031de9e Bump github.com/stretchr/testify from 1.2.2 to 1.5.1 (#62)
Bumps [github.com/stretchr/testify](https://github.com/stretchr/testify) from 1.2.2 to 1.5.1.
- [Release notes](https://github.com/stretchr/testify/releases)
- [Commits](https://github.com/stretchr/testify/compare/v1.2.2...v1.5.1)

Signed-off-by: dependabot-preview[bot] <support@dependabot.com>

Co-authored-by: dependabot-preview[bot] <27856297+dependabot-preview[bot]@users.noreply.github.com>
Co-authored-by: James Mills <prologic@shortcircuit.net.au>
2020-05-05 15:08:14 +10:00
dependabot-preview[bot]
a49dea57d8 Bump github.com/imdario/mergo from 0.3.6 to 0.3.9 (#65)
Bumps [github.com/imdario/mergo](https://github.com/imdario/mergo) from 0.3.6 to 0.3.9.
- [Release notes](https://github.com/imdario/mergo/releases)
- [Commits](https://github.com/imdario/mergo/compare/v0.3.6...v0.3.9)

Signed-off-by: dependabot-preview[bot] <support@dependabot.com>

Co-authored-by: dependabot-preview[bot] <27856297+dependabot-preview[bot]@users.noreply.github.com>
Co-authored-by: James Mills <prologic@shortcircuit.net.au>
2020-05-05 15:07:20 +10:00
dependabot-preview[bot]
114c6aa80c Bump github.com/sirupsen/logrus from 1.2.0 to 1.6.0 (#66)
Bumps [github.com/sirupsen/logrus](https://github.com/sirupsen/logrus) from 1.2.0 to 1.6.0.
- [Release notes](https://github.com/sirupsen/logrus/releases)
- [Changelog](https://github.com/sirupsen/logrus/blob/master/CHANGELOG.md)
- [Commits](https://github.com/sirupsen/logrus/compare/v1.2.0...v1.6.0)

Signed-off-by: dependabot-preview[bot] <support@dependabot.com>

Co-authored-by: dependabot-preview[bot] <27856297+dependabot-preview[bot]@users.noreply.github.com>
2020-05-05 15:06:41 +10:00
James Mills
414c2fcf89 Added DependaBot config 2019-12-26 14:03:06 +10:00
James Mills
9d860692fa Update Drone CI config 2018-12-31 20:11:21 +10:00
James Mills
98cb66559a Migrate to Drone CI, Codecov and Go11Modules 2018-12-31 20:08:19 +10:00
James Mills
e14795818f Add related projects 2018-11-27 05:49:17 +10:00
James Mills
c394ea6735 Set theme jekyll-theme-architect 2018-11-27 05:41:33 +10:00
James Mills
c94884fb9f Add webhook for local CI 2018-05-19 14:00:00 -07:00
James Mills
784039998f Fixed local CI notify email settings 2018-05-19 13:35:25 -07:00
James Mills
6981b10763 Create PULL_REQUEST_TEMPLATE.md 2018-05-19 13:21:30 -07:00
James Mills
d170e01d38 Update issue templates 2018-05-19 13:20:24 -07:00
James Mills
5787059d11 Create CODE_OF_CONDUCT.md (#50) 2018-05-19 13:19:01 -07:00
44 changed files with 522 additions and 296 deletions

8
.dependabot/config.yml Normal file
View File

@@ -0,0 +1,8 @@
version: 1
update_configs:
- package_manager: "go:modules"
directory: "/"
update_schedule: "daily"
- package_manager: "docker"
directory: "/"
update_schedule: "weekly"

View File

@@ -1,37 +0,0 @@
workspace:
base: /go
path: src/github.com/prologic/eris
pipeline:
build:
image: golang
commands:
- go get -d ./...
- go build .
test:
image: golang
commands:
- go get -d ./...
- go test ./...
docker:
image: plugins/docker
repo: r.mills.io/prologic/eris
registry: r.mills.io
secrets: [ docker_username, docker_password ]
notify:
image: drillster/drone-email
host: mail_poste
port: 25
from: drone@mills.io
skip_verify: true
when:
status: [ success, changed, failure ]
secrets:
registry_username:
external: true
registry_password:
external: true

35
.github/ISSUE_TEMPLATE/bug_report.md vendored Normal file
View File

@@ -0,0 +1,35 @@
---
name: Bug report
about: Create a report to help us improve
---
**Describe the bug**
A clear and concise description of what the bug is.
**To Reproduce**
Steps to reproduce the behavior:
1. Go to '...'
2. Click on '....'
3. Scroll down to '....'
4. See error
**Expected behavior**
A clear and concise description of what you expected to happen.
**Screenshots**
If applicable, add screenshots to help explain your problem.
**Desktop (please complete the following information):**
- OS: [e.g. iOS]
- Browser [e.g. chrome, safari]
- Version [e.g. 22]
**Smartphone (please complete the following information):**
- Device: [e.g. iPhone6]
- OS: [e.g. iOS8.1]
- Browser [e.g. stock browser, safari]
- Version [e.g. 22]
**Additional context**
Add any other context about the problem here.

View File

@@ -0,0 +1,17 @@
---
name: Feature request
about: Suggest an idea for this project
---
**Is your feature request related to a problem? Please describe.**
A clear and concise description of what the problem is. Ex. I'm always frustrated when [...]
**Describe the solution you'd like**
A clear and concise description of what you want to happen.
**Describe alternatives you've considered**
A clear and concise description of any alternative solutions or features you've considered.
**Additional context**
Add any other context or screenshots about the feature request here.

35
.github/workflows/build.yml vendored Normal file
View File

@@ -0,0 +1,35 @@
---
name: Build
on:
push:
branches:
- master
pull_request:
jobs:
build:
name: Build
strategy:
matrix:
go-version:
- "1.12.x"
- "1.13.x"
- "1.14.x"
os:
- "ubuntu-latest"
- "macos-latest"
- "windows-latest"
runs-on: ${{ matrix.os }}
steps:
- name: Setup Go ${{ matrix.go-version }}
uses: actions/setup-go@v1
with:
go-version: ${{ matrix.go-version }}
id: go
- name: Checkout
uses: actions/checkout@v2
- name: Build
run: |
go build -v .
- name: Test
run: |
go test -v -race .

10
.gitignore vendored
View File

@@ -1,7 +1,9 @@
*~*
bin
dist
*~
*.db
*.bak
*.pem
eris
/bin
/dist
/eris
/coverage.txt

60
.gitmodules vendored
View File

@@ -1,60 +0,0 @@
[submodule "vendor/github.com/sirupsen/logrus"]
path = vendor/github.com/sirupsen/logrus
url = https://github.com/sirupsen/logrus
[submodule "vendor/golang.org/x/crypto"]
path = vendor/golang.org/x/crypto
url = https://go.googlesource.com/crypto
[submodule "vendor/golang.org/x/sys"]
path = vendor/golang.org/x/sys
url = https://go.googlesource.com/sys
[submodule "vendor/github.com/DanielOaks/girc-go"]
path = vendor/github.com/DanielOaks/girc-go
url = https://github.com/DanielOaks/girc-go
[submodule "vendor/github.com/goshuirc/e-nfa"]
path = vendor/github.com/goshuirc/e-nfa
url = https://github.com/goshuirc/e-nfa
[submodule "vendor/github.com/imdario/mergo"]
path = vendor/github.com/imdario/mergo
url = https://github.com/imdario/mergo
[submodule "vendor/golang.org/x/text"]
path = vendor/golang.org/x/text
url = https://go.googlesource.com/text
[submodule "vendor/gopkg.in/yaml.v2"]
path = vendor/gopkg.in/yaml.v2
url = https://gopkg.in/yaml.v2
[submodule "vendor/github.com/prometheus/client_golang"]
path = vendor/github.com/prometheus/client_golang
url = https://github.com/prometheus/client_golang
[submodule "vendor/github.com/beorn7/perks"]
path = vendor/github.com/beorn7/perks
url = https://github.com/beorn7/perks
[submodule "vendor/github.com/golang/protobuf"]
path = vendor/github.com/golang/protobuf
url = https://github.com/golang/protobuf
[submodule "vendor/github.com/prometheus/client_model"]
path = vendor/github.com/prometheus/client_model
url = https://github.com/prometheus/client_model
[submodule "vendor/github.com/prometheus/common"]
path = vendor/github.com/prometheus/common
url = https://github.com/prometheus/common
[submodule "vendor/github.com/matttproud/golang_protobuf_extensions"]
path = vendor/github.com/matttproud/golang_protobuf_extensions
url = https://github.com/matttproud/golang_protobuf_extensions
[submodule "vendor/github.com/prometheus/procfs"]
path = vendor/github.com/prometheus/procfs
url = https://github.com/prometheus/procfs
[submodule "vendor/github.com/thoj/go-ircevent"]
path = vendor/github.com/thoj/go-ircevent
url = https://github.com/thoj/go-ircevent
[submodule "vendor/github.com/stretchr/testify"]
path = vendor/github.com/stretchr/testify
url = https://github.com/stretchr/testify
[submodule "vendor/github.com/renstrom/shortuuid"]
path = vendor/github.com/renstrom/shortuuid
url = https://github.com/renstrom/shortuuid
[submodule "vendor/github.com/mmcloughlin/professor"]
path = vendor/github.com/mmcloughlin/professor
url = https://github.com/mmcloughlin/professor
[submodule "vendor/github.com/google/uuid"]
path = vendor/github.com/google/uuid
url = https://github.com/google/uuid

View File

@@ -1,8 +0,0 @@
language: go
sudo: false
go:
- tip
before_install:
- go get github.com/mattn/goveralls
script:
- $HOME/gopath/bin/goveralls -service=travis-ci

29
.yamllint.yml Normal file
View File

@@ -0,0 +1,29 @@
---
yaml-files:
- '*.yaml'
- '*.yml'
- '.yamllint'
rules:
braces: enable
brackets: enable
colons: enable
commas: enable
comments: disable
comments-indentation: disable
document-end: disable
document-start:
level: warning
empty-lines: enable
empty-values: disable
hyphens: enable
indentation: enable
key-duplicates: enable
key-ordering: disable
line-length: disable
new-line-at-end-of-file: enable
new-lines: enable
octal-values: enable
quoted-strings: disable
trailing-spaces: enable
truthy: disable

46
CODE_OF_CONDUCT.md Normal file
View File

@@ -0,0 +1,46 @@
# Contributor Covenant Code of Conduct
## Our Pledge
In the interest of fostering an open and welcoming environment, we as contributors and maintainers pledge to making participation in our project and our community a harassment-free experience for everyone, regardless of age, body size, disability, ethnicity, gender identity and expression, level of experience, nationality, personal appearance, race, religion, or sexual identity and orientation.
## Our Standards
Examples of behavior that contributes to creating a positive environment include:
* Using welcoming and inclusive language
* Being respectful of differing viewpoints and experiences
* Gracefully accepting constructive criticism
* Focusing on what is best for the community
* Showing empathy towards other community members
Examples of unacceptable behavior by participants include:
* The use of sexualized language or imagery and unwelcome sexual attention or advances
* Trolling, insulting/derogatory comments, and personal or political attacks
* Public or private harassment
* Publishing others' private information, such as a physical or electronic address, without explicit permission
* Other conduct which could reasonably be considered inappropriate in a professional setting
## Our Responsibilities
Project maintainers are responsible for clarifying the standards of acceptable behavior and are expected to take appropriate and fair corrective action in response to any instances of unacceptable behavior.
Project maintainers have the right and responsibility to remove, edit, or reject comments, commits, code, wiki edits, issues, and other contributions that are not aligned to this Code of Conduct, or to ban temporarily or permanently any contributor for other behaviors that they deem inappropriate, threatening, offensive, or harmful.
## Scope
This Code of Conduct applies both within project spaces and in public spaces when an individual is representing the project or its community. Examples of representing a project or community include using an official project e-mail address, posting via an official social media account, or acting as an appointed representative at an online or offline event. Representation of a project may be further defined and clarified by project maintainers.
## Enforcement
Instances of abusive, harassing, or otherwise unacceptable behavior may be reported by contacting the project team at prologic@shortcircuit.net.au. The project team will review and investigate all complaints, and will respond in a way that it deems appropriate to the circumstances. The project team is obligated to maintain confidentiality with regard to the reporter of an incident. Further details of specific enforcement policies may be posted separately.
Project maintainers who do not follow or enforce the Code of Conduct in good faith may face temporary or permanent repercussions as determined by other members of the project's leadership.
## Attribution
This Code of Conduct is adapted from the [Contributor Covenant][homepage], version 1.4, available at [http://contributor-covenant.org/version/1/4][version]
[homepage]: http://contributor-covenant.org
[version]: http://contributor-covenant.org/version/1/4/

View File

@@ -33,7 +33,7 @@ bench:
@go test -v -bench ./...
test:
@go test -v -cover -race ./...
@go test -v -cover -coverprofile=coverage.txt -covermode=atomic -coverpkg=./... -race ./...
clean:
@rm -rf $(APP)
@git clean -f -d -X

3
PULL_REQUEST_TEMPLATE.md Normal file
View File

@@ -0,0 +1,3 @@
<one line description here>
Fixes #xx

View File

@@ -1,10 +1,10 @@
eris - IRC Server / Daemon written in Go
[![Build Status](https://travis-ci.org/prologic/eris.svg)](https://travis-ci.org/prologic/eris)
[![Go Report Card](https://goreportcard.com/badge/github.com/prologic/eris)](https://goreportcard.com/report/github.com/prologic/eris)
[![Coverage](https://coveralls.io/repos/prologic/eris/badge.svg)](https://coveralls.io/r/prologic/eris)
[![GoDoc](https://godoc.org/github.com/prologic/eris?status.svg)](https://godoc.org/github.com/prologic/eris)
[![Wiki](https://img.shields.io/badge/docs-wiki-blue.svg)](https://github.com/prologic/eris/wiki)
[![Build Status](https://cloud.drone.io/api/badges/prologic/eris/status.svg)](https://cloud.drone.io/prologic/eris)
[![CodeCov](https://codecov.io/gh/prologic/eris/branch/master/graph/badge.svg)](https://codecov.io/gh/prologic/eris)
[![Go Report Card](https://goreportcard.com/badge/prologic/eris)](https://goreportcard.com/report/prologic/eris)
[![GoDoc](https://godoc.org/github.com/prologic/eris?status.svg)](https://godoc.org/github.com/prologic/eris)
[![Sourcegraph](https://sourcegraph.com/github.com/prologic/eris/-/badge.svg)](https://sourcegraph.com/github.com/prologic/eris?badge)
> This project and repository is based off of [ergonomadic](https://github.com/edmund-huber/ergonomadic)
> and much of my original contributions were made in my [fork of ergonomadic](https://github.com/prologic/ergonomadic)
@@ -170,6 +170,11 @@ There are a number of supported accompanying services that are being developed a
* [Dispatch](https://github.com/khlieng/dispatch) -- TLS, Multiple Servers and Users, Client Certificates
## Related Projects
* [cadmus](https://github.com/prologic/cadmus) -- an IRC Bot written in Go that logs IRC Channels and provides an interface to view and search those logs
* [soter](https://github.com/prologic/soter) -- an IRC Bot written in Go that protects IRC Channels by persisting channel modes and topics
## License
eris is licensed under the MIT License.

1
_config.yml Normal file
View File

@@ -0,0 +1 @@
theme: jekyll-theme-architect

19
go.mod Normal file
View File

@@ -0,0 +1,19 @@
module github.com/prologic/eris
go 1.14
require (
github.com/DanielOaks/girc-go v0.0.0-20180430075055-8d136c4f9287
github.com/google/uuid v1.1.0 // indirect
github.com/goshuirc/e-nfa v0.0.0-20160917075329-7071788e3940 // indirect
github.com/imdario/mergo v0.3.11
github.com/mmcloughlin/professor v0.0.0-20170922221822-6b97112ab8b3
github.com/prometheus/client_golang v0.9.4
github.com/renstrom/shortuuid v3.0.0+incompatible
github.com/sirupsen/logrus v1.7.0
github.com/stretchr/testify v1.6.0
github.com/thoj/go-ircevent v0.0.0-20180816043103-14f3614f28c3
golang.org/x/crypto v0.0.0-20181203042331-505ab145d0a9
golang.org/x/text v0.3.4
gopkg.in/yaml.v2 v2.3.0
)

100
go.sum Normal file
View File

@@ -0,0 +1,100 @@
github.com/DanielOaks/girc-go v0.0.0-20180430075055-8d136c4f9287 h1:xOE8jDDulcwdPG+coLps6seNn6yERt5xgKSATNqWUM0=
github.com/DanielOaks/girc-go v0.0.0-20180430075055-8d136c4f9287/go.mod h1:nn+Gr++RLey8iGwfvI84UO5oZal6Muz7qPxDII0BsQ8=
github.com/alecthomas/template v0.0.0-20160405071501-a0175ee3bccc/go.mod h1:LOuyumcjzFXgccqObfd/Ljyb9UuFJ6TxHnclSeseNhc=
github.com/alecthomas/units v0.0.0-20151022065526-2efee857e7cf/go.mod h1:ybxpYRFXyAe+OPACYpWeL0wqObRcbAqCMya13uyzqw0=
github.com/beorn7/perks v0.0.0-20180321164747-3a771d992973 h1:xJ4a3vCFaGF/jqvzLMYoU8P317H5OQ+Via4RmuPwCS0=
github.com/beorn7/perks v0.0.0-20180321164747-3a771d992973/go.mod h1:Dwedo/Wpr24TaqPxmxbtue+5NUziq4I4S80YR8gNf3Q=
github.com/beorn7/perks v1.0.0 h1:HWo1m869IqiPhD389kmkxeTalrjNbbJTC8LXupb+sl0=
github.com/beorn7/perks v1.0.0/go.mod h1:KWe93zE9D1o94FZ5RNwFwVgaQK1VOXiVxmqh+CedLV8=
github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
github.com/go-kit/kit v0.8.0/go.mod h1:xBxKIO96dXMWWy0MnWVtmwkA9/13aqxPnvrjFYMA2as=
github.com/go-logfmt/logfmt v0.3.0/go.mod h1:Qt1PoO58o5twSAckw1HlFXLmHsOX5/0LbT9GBnD5lWE=
github.com/go-stack/stack v1.8.0/go.mod h1:v0f6uXyyMGvRgIKkXu+yp6POWl0qKG85gN/melR3HDY=
github.com/gogo/protobuf v1.1.1/go.mod h1:r8qH/GZQm5c6nD/R0oafs1akxWv10x8SbQlK7atdtwQ=
github.com/golang/protobuf v1.2.0 h1:P3YflyNX/ehuJFLhxviNdFxQPkGK5cDcApsge1SqnvM=
github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
github.com/golang/protobuf v1.3.1 h1:YF8+flBXS5eO826T4nzqPrxfhQThhXl0YzfuUPu4SBg=
github.com/golang/protobuf v1.3.1/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
github.com/google/uuid v1.1.0 h1:Jf4mxPC/ziBnoPIdpQdPJ9OeiomAUHLvxmPRSPH9m4s=
github.com/google/uuid v1.1.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
github.com/goshuirc/e-nfa v0.0.0-20160917075329-7071788e3940 h1:KmRLPRstEJiE/9OjumKqI8Rccip8Qmyw2FwyTFxtVqs=
github.com/goshuirc/e-nfa v0.0.0-20160917075329-7071788e3940/go.mod h1:VOmrX6cmj7zwUeexC9HzznUdTIObHqIXUrWNYS+Ik7w=
github.com/imdario/mergo v0.3.9 h1:UauaLniWCFHWd+Jp9oCEkTBj8VO/9DKg3PV3VCNMDIg=
github.com/imdario/mergo v0.3.9/go.mod h1:2EnlNZ0deacrJVfApfmtdGgDfMuh/nq6Ok1EcJh5FfA=
github.com/imdario/mergo v0.3.11 h1:3tnifQM4i+fbajXKBHXWEH+KvNHqojZ778UH75j3bGA=
github.com/imdario/mergo v0.3.11/go.mod h1:jmQim1M+e3UYxmgPu/WyfjB3N3VflVyUjjjwH0dnCYA=
github.com/json-iterator/go v1.1.6/go.mod h1:+SdeFBvtyEkXs7REEP0seUULqWtbJapLOCVDaaPEHmU=
github.com/julienschmidt/httprouter v1.2.0/go.mod h1:SYymIcj16QtmaHHD7aYtjjsJG7VTCxuUUipMqKk8s4w=
github.com/konsorten/go-windows-terminal-sequences v1.0.1/go.mod h1:T0+1ngSBFLxvqU3pZ+m/2kptfBszLMUkC4ZK/EgS/cQ=
github.com/konsorten/go-windows-terminal-sequences v1.0.3 h1:CE8S1cTafDpPvMhIxNJKvHsGVBgn1xWYf1NbHQhywc8=
github.com/konsorten/go-windows-terminal-sequences v1.0.3/go.mod h1:T0+1ngSBFLxvqU3pZ+m/2kptfBszLMUkC4ZK/EgS/cQ=
github.com/kr/logfmt v0.0.0-20140226030751-b84e30acd515/go.mod h1:+0opPa2QZZtGFBFZlji/RkVcI2GknAs/DXo4wKdlNEc=
github.com/matttproud/golang_protobuf_extensions v1.0.1 h1:4hp9jkHxhMHkqkrB3Ix0jegS5sx/RkqARlsWZ6pIwiU=
github.com/matttproud/golang_protobuf_extensions v1.0.1/go.mod h1:D8He9yQNgCq6Z5Ld7szi9bcBfOoFv/3dc6xSMkL2PC0=
github.com/mmcloughlin/professor v0.0.0-20170922221822-6b97112ab8b3 h1:2YMbJ6WbdQI9K73chxh9OWMDsZ2PNjAIRGTonp3T0l0=
github.com/mmcloughlin/professor v0.0.0-20170922221822-6b97112ab8b3/go.mod h1:LQkXsHRSPIEklPCq8OMQAzYNS2NGtYStdNE/ej1oJU8=
github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=
github.com/modern-go/reflect2 v1.0.1/go.mod h1:bx2lNnkwVCuqBIxFjflWJWanXIb3RllmbCylyMrvgv0=
github.com/mwitkow/go-conntrack v0.0.0-20161129095857-cc309e4a2223/go.mod h1:qRWi+5nqEBWmkhHvq77mSJWrCKwh8bxhgT7d/eI7P4U=
github.com/pkg/errors v0.8.0/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
github.com/prometheus/client_golang v0.9.1/go.mod h1:7SWBe2y4D6OKWSNQJUaRYU/AaXPKyh/dDVn+NZz0KFw=
github.com/prometheus/client_golang v0.9.4 h1:Y8E/JaaPbmFSW2V81Ab/d8yZFYQQGbni1b1jPcG9Y6A=
github.com/prometheus/client_golang v0.9.4/go.mod h1:oCXIBxdI62A4cR6aTRJCgetEjecSIYzOEaeAn4iYEpM=
github.com/prometheus/client_model v0.0.0-20180712105110-5c3871d89910 h1:idejC8f05m9MGOsuEi1ATq9shN03HrxNkD/luQvxCv8=
github.com/prometheus/client_model v0.0.0-20180712105110-5c3871d89910/go.mod h1:MbSGuTsp3dbXC40dX6PRTWyKYBIrTGTE9sqQNg2J8bo=
github.com/prometheus/client_model v0.0.0-20190129233127-fd36f4220a90 h1:S/YWwWx/RA8rT8tKFRuGUZhuA90OyIBpPCXkcbwU8DE=
github.com/prometheus/client_model v0.0.0-20190129233127-fd36f4220a90/go.mod h1:xMI15A0UPsDsEKsMN9yxemIoYk6Tm2C1GtYGdfGttqA=
github.com/prometheus/common v0.4.1 h1:K0MGApIoQvMw27RTdJkPbr3JZ7DNbtxQNyi5STVM6Kw=
github.com/prometheus/common v0.4.1/go.mod h1:TNfzLD0ON7rHzMJeJkieUDPYmFC7Snx/y86RQel1bk4=
github.com/prometheus/procfs v0.0.0-20181005140218-185b4288413d/go.mod h1:c3At6R/oaqEKCNdg8wHV1ftS6bRYblBhIjjI8uT2IGk=
github.com/prometheus/procfs v0.0.2 h1:6LJUbpNm42llc4HRCuvApCSWB/WfhuNo9K98Q9sNGfs=
github.com/prometheus/procfs v0.0.2/go.mod h1:TjEm7ze935MbeOT/UhFTIMYKhuLP4wbCsTZCD3I8kEA=
github.com/renstrom/shortuuid v3.0.0+incompatible h1:F6T1U7bWlI3FTV+JE8HyeR7bkTeYZJntqQLA9ST4HOQ=
github.com/renstrom/shortuuid v3.0.0+incompatible/go.mod h1:n18Ycpn8DijG+h/lLBQVnGKv1BCtTeXo8KKSbBOrQ8c=
github.com/sirupsen/logrus v1.2.0 h1:juTguoYk5qI21pwyTXY3B3Y5cOTH3ZUyZCg1v/mihuo=
github.com/sirupsen/logrus v1.2.0/go.mod h1:LxeOpSwHxABJmUn/MG1IvRgCAasNZTLOkJPxbbu5VWo=
github.com/sirupsen/logrus v1.6.0 h1:UBcNElsrwanuuMsnGSlYmtmgbb23qDR5dG+6X6Oo89I=
github.com/sirupsen/logrus v1.6.0/go.mod h1:7uNnSEd1DgxDLC74fIahvMZmmYsHGZGEOFrfsX/uA88=
github.com/sirupsen/logrus v1.7.0 h1:ShrD1U9pZB12TX0cVy0DtePoCH97K8EtX+mg7ZARUtM=
github.com/sirupsen/logrus v1.7.0/go.mod h1:yWOB1SBYBC5VeMP7gHvWumXLIWorT60ONWic61uBYv0=
github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
github.com/stretchr/objx v0.1.1 h1:2vfRuCMp5sSVIDSqO8oNnWJq7mPa6KVP3iPIwFBuy8A=
github.com/stretchr/objx v0.1.1/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
github.com/stretchr/testify v1.2.2 h1:bSDNvY7ZPG5RlJ8otE/7V6gMiyenm9RtJ7IUVIAoJ1w=
github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs=
github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
github.com/stretchr/testify v1.6.0 h1:jlIyCplCJFULU/01vCkhKuTyc3OorI3bJFuw6obfgho=
github.com/stretchr/testify v1.6.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
github.com/thoj/go-ircevent v0.0.0-20180816043103-14f3614f28c3 h1:389FrrKIAlxqQMTscCQ7VH3JAVuxb/pe53v2LBiA7z8=
github.com/thoj/go-ircevent v0.0.0-20180816043103-14f3614f28c3/go.mod h1:QYOctLs5qEsaIrA/PKEc4YqAv2SozbxNEX0vMPs84p4=
golang.org/x/crypto v0.0.0-20180904163835-0709b304e793/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4=
golang.org/x/crypto v0.0.0-20181203042331-505ab145d0a9 h1:mKdxBk7AujPs8kU4m80U72y/zjbZ3UcXC7dClwKbUI0=
golang.org/x/crypto v0.0.0-20181203042331-505ab145d0a9/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4=
golang.org/x/net v0.0.0-20181114220301-adae6a3d119a/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
golang.org/x/sync v0.0.0-20181108010431-42b317875d0f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
golang.org/x/sync v0.0.0-20181221193216-37e7f081c4d4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
golang.org/x/sys v0.0.0-20180905080454-ebe1bf3edb33 h1:I6FyU15t786LL7oL/hn43zqTuEGr4PN7F4XJ1p4E3Y8=
golang.org/x/sys v0.0.0-20180905080454-ebe1bf3edb33/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
golang.org/x/sys v0.0.0-20181116152217-5ac8a444bdc5/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
golang.org/x/sys v0.0.0-20190422165155-953cdadca894 h1:Cz4ceDQGXuKRnVBDTS23GTn/pU5OE2C0WrNTOYK1Uuc=
golang.org/x/sys v0.0.0-20190422165155-953cdadca894/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20191026070338-33540a1f6037 h1:YyJpGZS1sBuBCzLAR1VEpK193GlqGZbnPFnPV/5Rsb4=
golang.org/x/sys v0.0.0-20191026070338-33540a1f6037/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/text v0.3.2 h1:tW2bmiBqwgJj/UpqtC8EpXEZVYOwU0yG4iWbprSVAcs=
golang.org/x/text v0.3.2/go.mod h1:bEr9sfX3Q8Zfm5fL9x+3itogRgK3+ptLWKqgva+5dAk=
golang.org/x/text v0.3.3 h1:cokOdA+Jmi5PJGXLlLllQSgYigAEfHXJAERHVMaCc2k=
golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
golang.org/x/text v0.3.4/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
gopkg.in/alecthomas/kingpin.v2 v2.2.6/go.mod h1:FMv+mEhP44yOT+4EoQTLFTRgOQ1FBLkstjWtayDeSgw=
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM=
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
gopkg.in/yaml.v2 v2.2.1/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
gopkg.in/yaml.v2 v2.3.0 h1:clyUAQHOM3G0M3f5vQj7LuJrETvjVot3Z5el9nffUtU=
gopkg.in/yaml.v2 v2.3.0/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c h1:dUUwHk2QECo/6vqA44rthZ8ie2QXMNeKRTHCNY2nXvo=
gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=

View File

@@ -51,7 +51,7 @@ func (channel *Channel) Names(client *Client) {
}
func (channel *Channel) ClientIsOperator(client *Client) bool {
return client.flags[Operator] || channel.members.HasMode(client, ChannelOperator)
return client.modes.Has(Operator) || channel.members.HasMode(client, ChannelOperator)
}
func (channel *Channel) Nicks(target *Client) []string {
@@ -96,7 +96,7 @@ func (channel *Channel) String() string {
// <mode> <mode params>
func (channel *Channel) ModeString(client *Client) (str string) {
isMember := client.flags[Operator] || channel.members.Has(client)
isMember := client.modes.Has(Operator) || channel.members.Has(client)
showKey := isMember && (channel.key != "")
showUserLimit := channel.userLimit > 0
@@ -244,7 +244,7 @@ func (channel *Channel) CanSpeak(client *Client) bool {
channel.members.HasMode(client, ChannelOperator)) {
return false
}
if channel.flags.Has(SecureChan) && !client.flags[SecureConn] {
if channel.flags.Has(SecureChan) && !client.modes.Has(SecureConn) {
return false
}
return true
@@ -513,7 +513,7 @@ func (channel *Channel) Invite(invitee *Client, inviter *Client) {
inviter.RplInviting(invitee, channel.name)
invitee.Reply(RplInviteMsg(inviter, invitee, channel.name))
if invitee.flags[Away] {
if invitee.modes.Has(Away) {
inviter.RplAway(invitee)
}
}

View File

@@ -47,7 +47,7 @@ type Client struct {
capState CapState
channels *ChannelSet
ctime time.Time
flags map[UserMode]bool
modes *UserModeSet
hasQuit *SyncBool
hops uint
hostname Name
@@ -67,14 +67,14 @@ type Client struct {
func NewClient(server *Server, conn net.Conn) *Client {
now := time.Now()
client := &Client{
c := &Client{
atime: now,
authorized: len(server.password) == 0,
capState: CapNone,
capabilities: make(CapabilitySet),
channels: NewChannelSet(),
ctime: now,
flags: make(map[UserMode]bool),
modes: NewUserModeSet(),
hasQuit: NewSyncBool(false),
sasl: NewSaslState(),
server: server,
@@ -83,51 +83,50 @@ func NewClient(server *Server, conn net.Conn) *Client {
}
if _, ok := conn.(*tls.Conn); ok {
client.flags[SecureConn] = true
c.modes.Set(SecureConn)
}
client.Touch()
go client.writeloop()
go client.readloop()
c.Touch()
go c.writeloop()
go c.readloop()
return client
return c
}
//
// command goroutine
//
func (client *Client) writeloop() {
func (c *Client) writeloop() {
for {
select {
case reply, ok := <-client.replies:
if !ok || reply == "" || client.socket == nil {
case reply, ok := <-c.replies:
if !ok || reply == "" || c.socket == nil {
return
}
client.socket.Write(reply)
c.socket.Write(reply)
}
}
}
func (client *Client) readloop() {
func (c *Client) readloop() {
var command Command
var err error
var line string
// Set the hostname for this client.
client.hostname = AddrLookupHostname(client.socket.conn.RemoteAddr())
client.hostmask = NewName(SHA256(client.hostname.String()))
c.hostname = AddrLookupHostname(c.socket.conn.RemoteAddr())
c.hostmask = NewName(SHA256(c.hostname.String()))
for err == nil {
if line, err = client.socket.Read(); err != nil {
if line, err = c.socket.Read(); err != nil {
command = NewQuitCommand("connection closed")
} else if command, err = ParseCommand(line); err != nil {
switch err {
case ErrParseCommand:
//TODO(dan): use the real failed numeric for this (400)
client.Reply(RplNotice(client.server, client,
NewText("failed to parse command")))
c.Reply(RplNotice(c.server, c, NewText("failed to parse command")))
case NotEnoughArgsError:
// TODO
@@ -137,7 +136,7 @@ func (client *Client) readloop() {
continue
} else if checkPass, ok := command.(checkPasswordCommand); ok {
checkPass.LoadPassword(client.server)
checkPass.LoadPassword(c.server)
// Block the client thread while handling a potentially expensive
// password bcrypt operation. Since the server is single-threaded
// for commands, we don't want the server to perform the bcrypt,
@@ -146,189 +145,182 @@ func (client *Client) readloop() {
checkPass.CheckPassword()
}
client.processCommand(command)
c.processCommand(command)
}
}
func (client *Client) processCommand(cmd Command) {
cmd.SetClient(client)
func (c *Client) processCommand(cmd Command) {
cmd.SetClient(c)
if !client.registered {
if !c.registered {
regCmd, ok := cmd.(RegServerCommand)
if !ok {
client.Quit("unexpected command")
c.Quit("unexpected command")
return
}
regCmd.HandleRegServer(client.server)
regCmd.HandleRegServer(c.server)
return
}
srvCmd, ok := cmd.(ServerCommand)
if !ok {
client.ErrUnknownCommand(cmd.Code())
c.ErrUnknownCommand(cmd.Code())
return
}
client.server.metrics.Counter("client", "commands").Inc()
c.server.metrics.Counter("client", "commands").Inc()
defer func(t time.Time) {
v := client.server.metrics.SummaryVec("client", "command_duration_seconds")
v := c.server.metrics.SummaryVec("client", "command_duration_seconds")
v.WithLabelValues(cmd.Code().String()).Observe(time.Now().Sub(t).Seconds())
}(time.Now())
switch srvCmd.(type) {
case *PingCommand, *PongCommand:
client.Touch()
c.Touch()
case *QuitCommand:
// no-op
default:
client.Active()
client.Touch()
c.Active()
c.Touch()
}
srvCmd.HandleServer(client.server)
srvCmd.HandleServer(c.server)
}
// quit timer goroutine
func (client *Client) connectionTimeout() {
client.processCommand(NewQuitCommand("connection timeout"))
func (c *Client) connectionTimeout() {
c.processCommand(NewQuitCommand("connection timeout"))
}
//
// idle timer goroutine
//
func (client *Client) connectionIdle() {
client.server.idle <- client
func (c *Client) connectionIdle() {
c.server.idle <- c
}
//
// server goroutine
//
func (client *Client) Active() {
client.atime = time.Now()
func (c *Client) Active() {
c.atime = time.Now()
}
func (client *Client) Touch() {
if client.quitTimer != nil {
client.quitTimer.Stop()
func (c *Client) Touch() {
if c.quitTimer != nil {
c.quitTimer.Stop()
}
if client.idleTimer == nil {
client.idleTimer = time.AfterFunc(IDLE_TIMEOUT, client.connectionIdle)
if c.idleTimer == nil {
c.idleTimer = time.AfterFunc(IDLE_TIMEOUT, c.connectionIdle)
} else {
client.idleTimer.Reset(IDLE_TIMEOUT)
c.idleTimer.Reset(IDLE_TIMEOUT)
}
}
func (client *Client) Idle() {
client.pingTime = time.Now()
client.Reply(RplPing(client.server))
func (c *Client) Idle() {
c.pingTime = time.Now()
c.Reply(RplPing(c.server))
if client.quitTimer == nil {
client.quitTimer = time.AfterFunc(QUIT_TIMEOUT, client.connectionTimeout)
if c.quitTimer == nil {
c.quitTimer = time.AfterFunc(QUIT_TIMEOUT, c.connectionTimeout)
} else {
client.quitTimer.Reset(QUIT_TIMEOUT)
c.quitTimer.Reset(QUIT_TIMEOUT)
}
}
func (client *Client) Register() {
if client.registered {
func (c *Client) Register() {
if c.registered {
return
}
client.registered = true
client.flags[HostMask] = true
client.Touch()
c.registered = true
c.modes.Set(HostMask)
c.Touch()
}
func (client *Client) destroy() {
func (c *Client) destroy() {
// clean up channels
client.channels.Range(func(channel *Channel) bool {
channel.Quit(client)
c.channels.Range(func(channel *Channel) bool {
channel.Quit(c)
return true
})
// clean up server
if _, ok := client.socket.conn.(*tls.Conn); ok {
client.server.metrics.GaugeVec("server", "clients").WithLabelValues("secure").Dec()
if _, ok := c.socket.conn.(*tls.Conn); ok {
c.server.metrics.GaugeVec("server", "clients").WithLabelValues("secure").Dec()
} else {
client.server.metrics.GaugeVec("server", "clients").WithLabelValues("insecure").Dec()
c.server.metrics.GaugeVec("server", "clients").WithLabelValues("insecure").Dec()
}
client.server.connections.Dec()
client.server.clients.Remove(client)
c.server.connections.Dec()
c.server.clients.Remove(c)
// clean up self
if client.idleTimer != nil {
client.idleTimer.Stop()
if c.idleTimer != nil {
c.idleTimer.Stop()
}
if client.quitTimer != nil {
client.quitTimer.Stop()
if c.quitTimer != nil {
c.quitTimer.Stop()
}
close(client.replies)
close(c.replies)
client.socket.Close()
c.socket.Close()
log.Debugf("%s: destroyed", client)
log.Debugf("%s: destroyed", c)
}
func (client *Client) IdleTime() time.Duration {
return time.Since(client.atime)
func (c *Client) IdleTime() time.Duration {
return time.Since(c.atime)
}
func (client *Client) SignonTime() int64 {
return client.ctime.Unix()
func (c *Client) SignonTime() int64 {
return c.ctime.Unix()
}
func (client *Client) IdleSeconds() uint64 {
return uint64(client.IdleTime().Seconds())
func (c *Client) IdleSeconds() uint64 {
return uint64(c.IdleTime().Seconds())
}
func (client *Client) HasNick() bool {
return client.nick != ""
func (c *Client) HasNick() bool {
return c.nick != ""
}
func (client *Client) HasUsername() bool {
return client.username != ""
func (c *Client) HasUsername() bool {
return c.username != ""
}
func (client *Client) CanSpeak(target *Client) bool {
requiresSecure := client.flags[SecureOnly] || target.flags[SecureOnly]
isSecure := client.flags[SecureConn] && target.flags[SecureConn]
isOperator := client.flags[Operator]
func (c *Client) CanSpeak(target *Client) bool {
requiresSecure := c.modes.Has(SecureOnly) || target.modes.Has(SecureOnly)
isSecure := c.modes.Has(SecureConn) && target.modes.Has(SecureConn)
isOperator := c.modes.Has(Operator)
return !requiresSecure || (requiresSecure && (isOperator || isSecure))
}
// <mode>
func (c *Client) ModeString() (str string) {
for flag := range c.flags {
str += flag.String()
}
if len(str) > 0 {
str = "+" + str
}
return
return c.modes.String()
}
func (c *Client) UserHost(cloacked bool) Name {
username := "*"
if c.HasUsername() {
if c.username != "" {
username = c.username.String()
}
if cloacked {
return Name(fmt.Sprintf("%s!%s@%s", c.Nick(), username, c.hostmask))
return Name(fmt.Sprintf("%s!%s@%s", c.nick, username, c.hostmask))
}
return Name(fmt.Sprintf("%s!%s@%s", c.Nick(), username, c.hostname))
return Name(fmt.Sprintf("%s!%s@%s", c.nick, username, c.hostname))
}
func (c *Client) Server() Name {
@@ -354,10 +346,10 @@ func (c *Client) String() string {
return c.Id().String()
}
func (client *Client) Friends() *ClientSet {
func (c *Client) Friends() *ClientSet {
friends := NewClientSet()
friends.Add(client)
client.channels.Range(func(channel *Channel) bool {
friends.Add(c)
c.channels.Range(func(channel *Channel) bool {
channel.members.Range(func(member *Client, _ *ChannelModeSet) bool {
friends.Add(member)
return true
@@ -367,48 +359,48 @@ func (client *Client) Friends() *ClientSet {
return friends
}
func (client *Client) SetNickname(nickname Name) {
if client.HasNick() {
log.Errorf("%s nickname already set!", client)
func (c *Client) SetNickname(nickname Name) {
if c.nick != "" {
log.Errorf("%s nickname already set!", c)
return
}
client.nick = nickname
client.server.clients.Add(client)
c.nick = nickname
c.server.clients.Add(c)
}
func (client *Client) ChangeNickname(nickname Name) {
func (c *Client) ChangeNickname(nickname Name) {
// Make reply before changing nick to capture original source id.
reply := RplNick(client, nickname)
client.server.clients.Remove(client)
client.server.whoWas.Append(client)
client.nick = nickname
client.server.clients.Add(client)
client.Friends().Range(func(friend *Client) bool {
reply := RplNick(c, nickname)
c.server.clients.Remove(c)
c.server.whoWas.Append(c)
c.nick = nickname
c.server.clients.Add(c)
c.Friends().Range(func(friend *Client) bool {
friend.Reply(reply)
return true
})
}
func (client *Client) Reply(reply string) {
if !client.hasQuit.Get() {
client.replies <- reply
func (c *Client) Reply(reply string) {
if !c.hasQuit.Get() {
c.replies <- reply
}
}
func (client *Client) Quit(message Text) {
if client.hasQuit.Get() {
func (c *Client) Quit(message Text) {
if c.hasQuit.Get() {
return
}
client.hasQuit.Set(true)
client.Reply(RplError("quit"))
client.server.whoWas.Append(client)
friends := client.Friends()
friends.Remove(client)
client.destroy()
c.hasQuit.Set(true)
c.Reply(RplError("quit"))
c.server.whoWas.Append(c)
friends := c.Friends()
friends.Remove(c)
c.destroy()
if friends.Count() > 0 {
reply := RplQuit(client, message)
reply := RplQuit(c, message)
friends.Range(func(friend *Client) bool {
friend.Reply(reply)
return true

View File

@@ -108,7 +108,7 @@ func (m *ModeCommand) HandleServer(s *Server) {
return
}
if client != target && !client.flags[Operator] {
if client != target && !client.modes.Has(Operator) {
client.ErrUsersDontMatch()
return
}
@@ -120,26 +120,24 @@ func (m *ModeCommand) HandleServer(s *Server) {
case Invisible, HostMask, WallOps, SecureOnly:
switch change.op {
case Add:
if target.flags[change.mode] {
if target.modes.Has(change.mode) {
continue
}
target.flags[change.mode] = true
target.modes.Set(change.mode)
changes = append(changes, change)
case Remove:
if !target.flags[change.mode] {
if !target.modes.Has(change.mode) {
continue
}
delete(target.flags, change.mode)
target.modes.Unset(change.mode)
changes = append(changes, change)
}
case Operator:
if change.op == Remove {
if !target.flags[change.mode] {
if !target.modes.Has(change.mode) {
continue
}
delete(target.flags, change.mode)
target.modes.Unset(change.mode)
changes = append(changes, change)
}
}

View File

@@ -67,7 +67,7 @@ type OperNickCommand struct {
func (msg *OperNickCommand) HandleServer(server *Server) {
client := msg.Client()
if !client.flags[Operator] {
if !client.modes.Has(Operator) {
client.ErrNoPrivileges()
return
}

View File

@@ -5,9 +5,9 @@ func CanSeeChannel(client *Client, channel *Channel) bool {
isSecret := channel.flags.Has(Secret)
isMember := channel.members.Has(client)
isOperator := client.flags[Operator]
isRegistered := client.flags[Registered]
isSecure := client.flags[SecureConn]
isOperator := client.modes.Has(Operator)
isRegistered := client.modes.Has(Registered)
isSecure := client.modes.Has(SecureConn)
if !(isSecret || isPrivate) {
return true

View File

@@ -249,13 +249,13 @@ func (target *Client) RplRehashing() {
func (target *Client) RplWhois(client *Client) {
target.RplWhoisUser(client)
if client.flags[Operator] {
if client.modes.Has(Operator) {
target.RplWhoisOperator(client)
}
target.RplWhoisIdle(client)
target.RplWhoisChannels(client)
if client.flags[SecureConn] {
if client.modes.Has(SecureConn) {
target.RplWhoisSecure(client)
}
target.RplWhoisServer(client)
@@ -266,7 +266,7 @@ func (target *Client) RplWhois(client *Client) {
func (target *Client) RplWhoisUser(client *Client) {
var clientHost Name
if target.flags[Operator] || !client.flags[HostMask] {
if target.modes.Has(Operator) || !client.modes.Has(HostMask) {
clientHost = client.hostname
} else {
clientHost = client.hostmask
@@ -342,7 +342,7 @@ func (target *Client) RplChannelModeIs(channel *Channel) {
func (target *Client) RplWhoReply(channel *Channel, client *Client) {
var clientHost Name
if target.flags[Operator] || !client.flags[HostMask] {
if target.modes.Has(Operator) || !client.modes.Has(HostMask) {
clientHost = client.hostname
} else {
clientHost = client.hostmask
@@ -351,12 +351,12 @@ func (target *Client) RplWhoReply(channel *Channel, client *Client) {
channelName := "*"
flags := ""
if client.flags[Away] {
if client.modes.Has(Away) {
flags = "G"
} else {
flags = "H"
}
if client.flags[Operator] {
if client.modes.Has(Operator) {
flags += "*"
}
@@ -579,7 +579,7 @@ func (target *Client) RplLUserChannels() {
func (target *Client) RplLUserOp() {
nOperators := 0
target.server.clients.Range(func(_ Name, client *Client) bool {
if client.flags[Operator] {
if client.modes.Has(Operator) {
nOperators++
}
return true
@@ -610,7 +610,7 @@ func (target *Client) RplLUserMe() {
func (target *Client) RplWhoWasUser(whoWas *WhoWas) {
var whoWasHost Name
if target.flags[Operator] {
if target.modes.Has(Operator) {
whoWasHost = whoWas.hostname
} else {
whoWasHost = whoWas.hostmask

View File

@@ -173,7 +173,7 @@ func NewServer(config *Config) *Server {
func (server *Server) Wallops(message string) {
text := NewText(message)
server.clients.Range(func(_ Name, client *Client) bool {
if client.flags[WallOps] {
if client.modes.Has(WallOps) {
server.metrics.Counter("client", "messages").Inc()
client.replies <- RplNotice(server, client, text)
}
@@ -408,7 +408,7 @@ func (msg *RFC2812UserCommand) HandleRegServer(server *Server) {
flags := msg.Flags()
if len(flags) > 0 {
for _, mode := range flags {
client.flags[mode] = true
client.modes.Set(mode)
}
client.RplUModeIs(client)
}
@@ -495,7 +495,7 @@ func (msg *AuthenticateCommand) HandleRegServer(server *Server) {
client.RplLoggedIn(authcid)
client.RplSaslSuccess()
client.flags[Registered] = true
client.modes.Set(Registered)
client.Reply(
RplModeChanges(
client, client,
@@ -624,7 +624,7 @@ func (msg *PrivMsgCommand) HandleServer(server *Server) {
}
server.metrics.Counter("client", "messages").Inc()
target.Reply(RplPrivMsg(client, target, msg.message))
if target.flags[Away] {
if target.modes.Has(Away) {
client.RplAway(target)
}
}
@@ -673,7 +673,7 @@ func (m *WhoisCommand) HandleServer(server *Server) {
func whoChannel(client *Client, channel *Channel, friends *ClientSet) {
channel.members.Range(func(member *Client, _ *ChannelModeSet) bool {
if !client.flags[Invisible] || friends.Has(client) {
if !client.modes.Has(Invisible) || friends.Has(client) {
client.RplWhoReply(channel, member)
}
return true
@@ -715,8 +715,8 @@ func (msg *OperCommand) HandleServer(server *Server) {
return
}
client.flags[Operator] = true
client.flags[WallOps] = true
client.modes.Set(Operator)
client.modes.Set(WallOps)
client.RplYoureOper()
client.Reply(
RplModeChanges(
@@ -731,7 +731,7 @@ func (msg *OperCommand) HandleServer(server *Server) {
func (msg *RehashCommand) HandleServer(server *Server) {
client := msg.Client()
if !client.flags[Operator] {
if !client.modes.Has(Operator) {
client.ErrNoPrivileges()
return
}
@@ -756,9 +756,9 @@ func (msg *RehashCommand) HandleServer(server *Server) {
func (msg *AwayCommand) HandleServer(server *Server) {
client := msg.Client()
if len(msg.text) > 0 {
client.flags[Away] = true
client.modes.Set(Away)
} else {
delete(client.flags, Away)
client.modes.Unset(Away)
}
client.awayMessage = msg.text
}
@@ -783,7 +783,7 @@ func (msg *MOTDCommand) HandleServer(server *Server) {
func (msg *NoticeCommand) HandleServer(server *Server) {
client := msg.Client()
if msg.target == "*" && client.flags[Operator] {
if msg.target == "*" && client.modes.Has(Operator) {
server.Global(msg.message.String())
return
}
@@ -932,7 +932,7 @@ func (msg *LUsersCommand) HandleServer(server *Server) {
func (msg *WallopsCommand) HandleServer(server *Server) {
client := msg.Client()
if !client.flags[Operator] {
if !client.modes.Has(Operator) {
client.ErrNoPrivileges()
return
}
@@ -942,7 +942,7 @@ func (msg *WallopsCommand) HandleServer(server *Server) {
func (msg *KillCommand) HandleServer(server *Server) {
client := msg.Client()
if !client.flags[Operator] {
if !client.modes.Has(Operator) {
client.ErrNoPrivileges()
return
}

View File

@@ -94,6 +94,67 @@ func (c *ChannelNameMap) Remove(channel *Channel) error {
return nil
}
// UserModeSet holds a mapping of channel modes
type UserModeSet struct {
sync.RWMutex
modes map[UserMode]bool
}
// NewUserModeSet returns a new UserModeSet
func NewUserModeSet() *UserModeSet {
return &UserModeSet{modes: make(map[UserMode]bool)}
}
// Set sets mode
func (set *UserModeSet) Set(mode UserMode) {
set.Lock()
defer set.Unlock()
set.modes[mode] = true
}
// Unset unsets mode
func (set *UserModeSet) Unset(mode UserMode) {
set.Lock()
defer set.Unlock()
delete(set.modes, mode)
}
// Has returns true if the mode is set
func (set *UserModeSet) Has(mode UserMode) bool {
set.RLock()
defer set.RUnlock()
ok, _ := set.modes[mode]
return ok
}
// Range ranges of the modes calling f
func (set *UserModeSet) Range(f func(mode UserMode) bool) {
set.RLock()
defer set.RUnlock()
for mode := range set.modes {
if !f(mode) {
return
}
}
}
// String returns a string representing the channel modes
func (set *UserModeSet) String() string {
set.RLock()
defer set.RUnlock()
if len(set.modes) == 0 {
return ""
}
strs := make([]string, len(set.modes))
index := 0
for mode := range set.modes {
strs[index] = mode.String()
index++
}
return strings.Join(strs, "")
}
// ChannelModeSet holds a mapping of channel modes
type ChannelModeSet struct {
sync.RWMutex

1
vendor/github.com/beorn7/perks generated vendored

1
vendor/github.com/google/uuid generated vendored

Submodule vendor/github.com/google/uuid deleted from dec09d789f

1
vendor/github.com/imdario/mergo generated vendored

1
vendor/golang.org/x/crypto generated vendored

Submodule vendor/golang.org/x/crypto deleted from 1a580b3eff

1
vendor/golang.org/x/sys generated vendored

Submodule vendor/golang.org/x/sys deleted from 7c87d13f8e

1
vendor/golang.org/x/text generated vendored

Submodule vendor/golang.org/x/text deleted from 5c1cf69b59

1
vendor/gopkg.in/yaml.v2 generated vendored

Submodule vendor/gopkg.in/yaml.v2 deleted from 5420a8b674