1 files changed, 107 insertions, 15 deletions

diff --git a/src/plugins/template_extractor.c b/src/plugins/template_extractor.c
index 63f0393..b6f3371 100644
--- a/src/plugins/template_extractor.c
+++ b/src/plugins/template_extractor.c
@@ -21,21 +21,113 @@
 #include "platform.h"
 #include "extractor.h"
 
-int 
-EXTRACTOR_template_extract (const unsigned char *data,
-                            size_t size,
-                            EXTRACTOR_MetaDataProcessor proc,
-                            void *proc_cls,
-                            const char *options)
+#include "extractor_plugins.h"
+
+struct template_state
+{
+  int state;
+
+  /* more state fields here
+   * all variables that should survive more than one atomic read
+   * from the "file" are to be placed here.
+   */
+};
+
+enum TemplateState
+{
+  TEMPLATE_INVALID = -1,
+  TEMPLATE_LOOKING_FOR_FOO = 0,
+  TEMPLATE_READING_FOO,
+  TEMPLATE_READING_BAR,
+  TEMPLATE_SEEKING_TO_ZOOL
+};
+
+void
+EXTRACTOR_template_init_state_method (struct EXTRACTOR_PluginList *plugin)
 {
-  if (0 != proc (proc_cls,
-                 "template",
-                 EXTRACTOR_METATYPE_RESERVED,
-                 EXTRACTOR_METAFORMAT_UTF8,
-                 "text/plain",
-                 "foo",
-                 strlen ("foo")+1))
+  struct template_state *state;
+  state = plugin->state = malloc (sizeof (struct template_state));
+  if (state == NULL)
+    return;
+  state->state = TEMPLATE_LOOKING_FOR_FOO; /* or whatever is the initial one */
+  /* initialize other fields to their "uninitialized" values or defaults */
+}
+
+void
+EXTRACTOR_template_discard_state_method (struct EXTRACTOR_PluginList *plugin)
+{
+  if (plugin->state != NULL)
+  {
+    /* free other state fields that are heap-allocated */
+    free (plugin->state);
+  }
+  plugin->state = NULL;
+}
+
+int
+EXTRACTOR_template_extract_method (struct EXTRACTOR_PluginList *plugin,
+    EXTRACTOR_MetaDataProcessor proc, void *proc_cls)
+{
+  int64_t file_position;
+  int64_t file_size;
+  size_t offset = 0;
+  size_t size;
+  unsigned char *data;
+  unsigned char *ff;
+  struct mp3_state *state;
+
+  /* temporary variables are declared here */
+
+  if (plugin == NULL || plugin->state == NULL)
     return 1;
-  /* insert more here */
-  return 0;
+
+  /* for easier access (and conforms better with the old plugins var names) */
+  state = plugin->state;
+  file_position = plugin->position;
+  file_size = plugin->fsize;
+  size = plugin->map_size;
+  data = plugin->shm_ptr;
+
+  /* sanity checks */
+  if (plugin->seek_request < 0)
+    return 1;
+  if (file_position - plugin->seek_request > 0)
+  {
+    plugin->seek_request = -1;
+    return 1;
+  }
+  if (plugin->seek_request - file_position < size)
+    offset = plugin->seek_request - file_position;
+
+  while (1)
+  {
+    switch (state->state)
+    {
+    case TEMPLATE_INVALID:
+      plugin->seek_request = -1;
+      return 1;
+    case TEMPLATE_LOOKING_FOR_FOO:
+      /* Find FOO in data buffer.
+       * If found, set offset to its position and set state to TEMPLATE_READING_FOO
+       * If not found, set seek_request to file_position + offset and return 1
+       * (but it's better to give up as early as possible, to avoid reading the whole
+       * file byte-by-byte).
+       */ 
+      break;
+    case TEMPLATE_READING_FOO:
+      /* See if offset + sizeof(foo) < size, otherwise set seek_request to offset and return 1;
+       * If file_position is 0, and size is still to small, give up.
+       * Read FOO, maybe increase offset to reflect that (depends on the parser logic).
+       * Either process FOO right here, or jump to another state (see ebml plugin for an example of complex
+       * state-jumps).
+       * If FOO says you need to seek somewhere - set offset to seek_target - file_position and set the
+       * next state (next state will check that offset < size; all states that do reading should do that,
+       * and also check for EOF).
+       */
+      /* ... */
+      break;
+    }
+  }
+  /* Should not reach this */
+  return 1;
 }