events.go

   1 /*
   2 goircd -- minimalistic simple Internet Relay Chat (IRC) server
   3 Copyright (C) 2014-2015 Sergey Matveev <stargrave@stargrave.org>
   4
   5 This program is free software: you can redistribute it and/or modify
   6 it under the terms of the GNU General Public License as published by
   7 the Free Software Foundation, either version 3 of the License, or
   8 (at your option) any later version.
   9
  10 This program is distributed in the hope that it will be useful,
  11 but WITHOUT ANY WARRANTY; without even the implied warranty of
  12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  13 GNU General Public License for more details.
  14
  15 You should have received a copy of the GNU General Public License
  16 along with this program.  If not, see <http://www.gnu.org/licenses/>.
  17 */
  18
  19 package main
  20
  21 import (
  22         "fmt"
  23         "io/ioutil"
  24         "log"
  25         "os"
  26         "path"
  27         "time"
  28 )
  29
  30 const (
  31         EventNew   = iota
  32         EventDel   = iota
  33         EventMsg   = iota
  34         EventTopic = iota
  35         EventWho   = iota
  36         EventMode  = iota
  37         FormatMsg  = "[%s] <%s> %s\n"
  38         FormatMeta = "[%s] * %s %s\n"
  39 )
  40
  41 // Client events going from each of client
  42 // They can be either NEW, DEL or unparsed MSG
  43 type ClientEvent struct {
  44         client    *Client
  45         eventType int
  46         text      string
  47 }
  48
  49 func (m ClientEvent) String() string {
  50         return string(m.eventType) + ": " + m.client.String() + ": " + m.text
  51 }
  52
  53 // Logging in-room events
  54 // Intended to tell when, where and who send a message or meta command
  55 type LogEvent struct {
  56         where string
  57         who   string
  58         what  string
  59         meta  bool
  60 }
  61
  62 // Logging events logger itself
  63 // Each room's events are written to separate file in logdir
  64 // Events include messages, topic and keys changes, joining and leaving
  65 func Logger(logdir string, events <-chan LogEvent) {
  66         mode := os.O_CREATE | os.O_WRONLY | os.O_APPEND
  67         perm := os.FileMode(0660)
  68         var format string
  69         for event := range events {
  70                 logfile := path.Join(logdir, event.where)
  71                 fd, err := os.OpenFile(logfile, mode, perm)
  72                 if err != nil {
  73                         log.Println("Can not open logfile", logfile, err)
  74                         continue
  75                 }
  76                 if event.meta {
  77                         format = FormatMeta
  78                 } else {
  79                         format = FormatMsg
  80                 }
  81                 _, err = fd.WriteString(fmt.Sprintf(format, time.Now(), event.who, event.what))
  82                 fd.Close()
  83                 if err != nil {
  84                         log.Println("Error writing to logfile", logfile, err)
  85                 }
  86         }
  87 }
  88
  89 type StateEvent struct {
  90         where string
  91         topic string
  92         key   string
  93 }
  94
  95 // Room state events saver
  96 // Room states shows that either topic or key has been changed
  97 // Each room's state is written to separate file in statedir
  98 func StateKeeper(statedir string, events <-chan StateEvent) {
  99         for event := range events {
 100                 fn := path.Join(statedir, event.where)
 101                 data := event.topic + "\n" + event.key + "\n"
 102                 err := ioutil.WriteFile(fn, []byte(data), os.FileMode(0660))
 103                 if err != nil {
 104                         log.Printf("Can not write statefile %s: %v", fn, err)
 105                 }
 106         }
 107 }