versaplexd/vxdbusschema.cs

   1 /*
   2  * Versaplex:
   3  *   Copyright (C)2007-2008 Versabanq Innovations Inc. and contributors.
   4  *       See the included file named LICENSE for license information.
   5  */
   6 using System;
   7 using System.Linq;
   8 using System.Collections;
   9 using System.Collections.Generic;
  10 using Wv;
  11 using Wv.Extensions;
  12
  13 // An ISchemaBackend that uses a DBus connection to Versaplex as a backing
  14 // store.
  15 [WvMoniker]
  16 internal class VxDbusSchema : ISchemaBackend
  17 {
  18     WvDbus bus;
  19
  20     public static void wvmoniker_register()
  21     {
  22         WvMoniker<ISchemaBackend>.register("vx",
  23                   (string m, object o) => new VxDbusSchema(m));
  24         WvMoniker<ISchemaBackend>.register("vx",
  25                   (string m, object o) => new VxDbusSchema(m));
  26     }
  27
  28     public VxDbusSchema()
  29         : this((string)null)
  30     {
  31     }
  32
  33     public VxDbusSchema(string busurl)
  34     {
  35         WvUrl url = new WvUrl(busurl);
  36
  37         if (url.host.e() || url.host == "session")
  38             bus = WvDbus.session_bus;
  39         else
  40             bus = new WvDbus(wv.fmt("tcp:host={0},port={1}",
  41                                     url.host, url.port));
  42     }
  43
  44     // If you've already got a Bus you'd like to use.
  45     public VxDbusSchema(WvDbus _bus)
  46     {
  47         bus = _bus;
  48     }
  49
  50     public void Dispose()
  51     {
  52         using (bus)
  53         {
  54             bus = null;
  55         }
  56     }
  57
  58     static WvDbusMsg methodcall(string method, string signature)
  59     {
  60         return new WvDbusCall("vx.versaplexd", "/db",
  61                               "vx.db", method, signature);
  62     }
  63
  64     //
  65     // The ISchema interface
  66     //
  67
  68     // Note: this implementation ignores the sums.
  69     public VxSchemaErrors Put(VxSchema schema, VxSchemaChecksums sums,
  70         VxPutOpts opts)
  71     {
  72         WvDbusMsg call = methodcall("PutSchema",
  73             String.Format("{0}i", VxSchema.GetDbusSignature()));
  74
  75         WvDbusWriter writer = new WvDbusWriter();
  76
  77         schema.WriteSchema(writer);
  78         writer.Write((int)opts);
  79         call.Body = writer.ToArray();
  80
  81         WvDbusMsg reply = bus.send_and_wait(call);
  82         if (reply.signature == VxSchemaErrors.GetDbusSignature())
  83             return new VxSchemaErrors(reply.iter().pop());
  84         else
  85             reply.check(VxSchemaErrors.GetDbusSignature());
  86         return null;
  87     }
  88
  89     // Utility API so you can say Get("foo").
  90     public VxSchema Get(params string[] keys)
  91     {
  92         WvDbusMsg call = methodcall("GetSchema", "as");
  93
  94         WvDbusWriter writer = new WvDbusWriter();
  95
  96         if (keys == null)
  97             keys = new string[0];
  98
  99         writer.WriteArray(4, keys, (w2, k) => {
 100             w2.Write(k);
 101         });
 102         call.Body = writer.ToArray();
 103
 104         WvDbusMsg reply = bus.send_and_wait(call);
 105         reply.check("a(sssy)");
 106         VxSchema schema = new VxSchema(reply.iter().pop());
 107         return schema;
 108     }
 109
 110     public VxSchema Get(IEnumerable<string> keys)
 111     {
 112         if (keys == null)
 113             keys = new string[0];
 114         return Get(keys.ToArray());
 115     }
 116
 117     public VxSchemaChecksums GetChecksums()
 118     {
 119         WvDbusMsg call = methodcall("GetSchemaChecksums", "");
 120
 121         WvDbusMsg reply = bus.send_and_wait(call);
 122         reply.check("a(sat)");
 123         VxSchemaChecksums sums = new VxSchemaChecksums(reply);
 124         return sums;
 125     }
 126
 127     public VxSchemaErrors DropSchema(IEnumerable<string> keys)
 128     {
 129         if (keys == null)
 130             keys = new string[0];
 131         return DropSchema(keys.ToArray());
 132     }
 133
 134     // A method exported over DBus but not exposed in ISchemaBackend
 135     public VxSchemaErrors DropSchema(params string[] keys)
 136     {
 137         WvDbusMsg call = methodcall("DropSchema", "as");
 138
 139         WvDbusWriter writer = new WvDbusWriter();
 140
 141         writer.WriteArray(4, keys, (w2, k) => {
 142             w2.Write(k);
 143         });
 144         call.Body = writer.ToArray();
 145
 146         WvDbusMsg reply = bus.send_and_wait(call);
 147         if (reply.signature == VxSchemaErrors.GetDbusSignature())
 148             return new VxSchemaErrors(reply.iter().pop());
 149         else
 150             reply.check(VxSchemaErrors.GetDbusSignature());
 151         return null;
 152     }
 153
 154     public string GetSchemaData(string tablename, int seqnum, string where,
 155                                 Dictionary<string,string> replaces, List<string> skipfields)
 156     {
 157         WvDbusMsg call = methodcall("GetSchemaData", "ss");
 158
 159         WvDbusWriter writer = new WvDbusWriter();
 160
 161         if (where == null)
 162             where = "";
 163
 164         writer.Write(tablename);
 165         writer.Write(where);
 166         call.Body = writer.ToArray();
 167
 168         WvDbusMsg reply = bus.send_and_wait(call);
 169         reply.check("s");
 170         return reply.iter().pop();
 171     }
 172
 173     public void PutSchemaData(string tablename, string text, int seqnum)
 174     {
 175         WvDbusMsg call = methodcall("PutSchemaData", "ss");
 176
 177         WvDbusWriter writer = new WvDbusWriter();
 178
 179         writer.Write(tablename);
 180         writer.Write(text);
 181         call.Body = writer.ToArray();
 182
 183         WvDbusMsg reply = bus.send_and_wait(call);
 184         reply.check("");
 185     }
 186 }
 187
 188