ci: format

.gitignore

@@ -1,6 +1,5 @@
 doc/tags
 *.log
-minimal_init.lua
 
 .*cache*
 CLAUDE.md

.luarc.json

@@ -2,14 +2,7 @@
   "runtime.version": "LuaJIT",
   "runtime.path": ["lua/?.lua", "lua/?/init.lua"],
   "diagnostics.globals": ["vim", "jit"],
-  "diagnostics.libraryFiles": "Disable",
+  "workspace.library": ["$VIMRUNTIME/lua", "${3rd}/luv/library"],
-  "workspace.library": [
-    "$VIMRUNTIME/lua",
-    "${3rd}/luv/library",
-    "${3rd}/busted/library",
-    "${3rd}/luassert/library"
-  ],
   "workspace.checkThirdParty": false,
-  "workspace.ignoreDir": [".direnv"],
   "completion.callSnippet": "Replace"
 }

README.md

@@ -1,15 +1,13 @@
 # pending.nvim
 
-Edit tasks like text. Inspired by
+Edit tasks like text. `:w` saves them.
-[oil.nvim](https://github.com/stevearc/oil.nvim),
-[vim-fugitive](https://github.com/tpope/vim-fugitive)
 
-![demo](assets/demo.gif)
+<!-- insert preview -->
 
 ## Requirements
 
 - Neovim 0.10+
-- (Optionally) `curl` for Google Calendar and Google Task sync
+- (Optionally) `curl` and `openssl` for Google Calendar and Google Task sync
 
 ## Installation
 

flake.nix

@@ -13,12 +13,9 @@
       ...
     }:
     let
-      forEachSystem =
+      forEachSystem = f: nixpkgs.lib.genAttrs (import systems) (system: f nixpkgs.legacyPackages.${system});
-        f: nixpkgs.lib.genAttrs (import systems) (system: f nixpkgs.legacyPackages.${system});
     in
     {
-      formatter = forEachSystem (pkgs: pkgs.nixfmt-tree);
-
       devShells = forEachSystem (pkgs: {
         default = pkgs.mkShell {
           packages = [

lua/pending/buffer.lua

@@ -1,12 +1,10 @@
 local config = require('pending.config')
+local store = require('pending.store')
 local views = require('pending.views')
 
 ---@class pending.buffer
 local M = {}
 
----@type pending.Store?
-local _store = nil
-
 ---@type integer?
 local task_bufnr = nil
 ---@type integer?
@@ -18,10 +16,6 @@ local current_view = nil
 local _meta = {}
 ---@type table<integer, table<string, boolean>>
 local _fold_state = {}
----@type string[]
-local _filter_predicates = {}
----@type table<integer, true>
-local _hidden_ids = {}
 
 ---@return pending.LineMeta[]
 function M.meta()
@@ -43,50 +37,12 @@ function M.current_view_name()
   return current_view
 end
 
----@param s pending.Store?
----@return nil
-function M.set_store(s)
-  _store = s
-end
-
----@return pending.Store?
-function M.store()
-  return _store
-end
-
----@return string[]
-function M.filter_predicates()
-  return _filter_predicates
-end
-
----@return table<integer, true>
-function M.hidden_ids()
-  return _hidden_ids
-end
-
----@param predicates string[]
----@param hidden table<integer, true>
----@return nil
-function M.set_filter(predicates, hidden)
-  _filter_predicates = predicates
-  _hidden_ids = hidden
-end
-
----@return nil
 function M.clear_winid()
   task_winid = nil
 end
 
----@return nil
 function M.close()
-  if not task_winid or not vim.api.nvim_win_is_valid(task_winid) then
+  if task_winid and vim.api.nvim_win_is_valid(task_winid) then
-    task_winid = nil
-    return
-  end
-  local wins = vim.api.nvim_list_wins()
-  if #wins == 1 then
-    vim.cmd.enew()
-  else
     vim.api.nvim_win_close(task_winid, false)
   end
   task_winid = nil
@@ -99,13 +55,19 @@ local function set_buf_options(bufnr)
   vim.bo[bufnr].swapfile = false
   vim.bo[bufnr].filetype = 'pending'
   vim.bo[bufnr].modifiable = true
-  vim.bo[bufnr].omnifunc = 'v:lua.require("pending.complete").omnifunc'
 end
 
 ---@param winid integer
 local function set_win_options(winid)
   vim.wo[winid].conceallevel = 3
   vim.wo[winid].concealcursor = 'nvic'
+  vim.wo[winid].wrap = false
+  vim.wo[winid].number = false
+  vim.wo[winid].relativenumber = false
+  vim.wo[winid].signcolumn = 'no'
+  vim.wo[winid].foldcolumn = '0'
+  vim.wo[winid].spell = false
+  vim.wo[winid].cursorline = true
   vim.wo[winid].winfixheight = true
 end
 
@@ -115,7 +77,7 @@ local function setup_syntax(bufnr)
     vim.cmd([[
       syntax clear
       syntax match taskId /^\/\d\+\// conceal
-      syntax match taskHeader /^# .*$/ contains=taskId
+      syntax match taskHeader /^## .*$/ contains=taskId
       syntax match taskCheckbox /\[!\]/ contained containedin=taskLine
       syntax match taskLine /^\/\d\+\/- \[.\] .*$/ contains=taskId,taskCheckbox
     ]])
@@ -123,7 +85,6 @@ local function setup_syntax(bufnr)
 end
 
 ---@param above boolean
----@return nil
 function M.open_line(above)
   local bufnr = task_bufnr
   if not bufnr or not vim.api.nvim_buf_is_valid(bufnr) then
@@ -156,34 +117,29 @@ end
 ---@param bufnr integer
 ---@param line_meta pending.LineMeta[]
 local function apply_extmarks(bufnr, line_meta)
-  local icons = config.get().icons
   vim.api.nvim_buf_clear_namespace(bufnr, task_ns, 0, -1)
   for i, m in ipairs(line_meta) do
     local row = i - 1
-    if m.type == 'filter' then
+    if m.type == 'task' then
-      local line = vim.api.nvim_buf_get_lines(bufnr, row, row + 1, false)[1] or ''
-      vim.api.nvim_buf_set_extmark(bufnr, task_ns, row, 0, {
-        end_col = #line,
-        hl_group = 'PendingFilter',
-      })
-    elseif m.type == 'task' then
       local due_hl = m.overdue and 'PendingOverdue' or 'PendingDue'
-      local virt_parts = {}
+      if m.show_category then
-      if m.show_category and m.category then
+        local virt_text
-        table.insert(virt_parts, { icons.category .. ' ' .. m.category, 'PendingHeader' })
+        if m.category and m.due then
-      end
+          virt_text = { { m.category .. '  ', 'PendingHeader' }, { m.due, due_hl } }
-      if m.recur then
+        elseif m.category then
-        table.insert(virt_parts, { icons.recur .. ' ' .. m.recur, 'PendingRecur' })
+          virt_text = { { m.category, 'PendingHeader' } }
-      end
+        elseif m.due then
-      if m.due then
+          virt_text = { { m.due, due_hl } }
-        table.insert(virt_parts, { icons.due .. ' ' .. m.due, due_hl })
-      end
-      if #virt_parts > 0 then
-        for p = 1, #virt_parts - 1 do
-          virt_parts[p][1] = virt_parts[p][1] .. '  '
         end
+        if virt_text then
+          vim.api.nvim_buf_set_extmark(bufnr, task_ns, row, 0, {
+            virt_text = virt_text,
+            virt_text_pos = 'eol',
+          })
+        end
+      elseif m.due then
         vim.api.nvim_buf_set_extmark(bufnr, task_ns, row, 0, {
-          virt_text = virt_parts,
+          virt_text = { { m.due, due_hl } },
           virt_text_pos = 'eol',
         })
       end
@@ -195,32 +151,12 @@ local function apply_extmarks(bufnr, line_meta)
           hl_group = 'PendingDone',
         })
       end
-      local line = vim.api.nvim_buf_get_lines(bufnr, row, row + 1, false)[1] or ''
-      local bracket_col = (line:find('%[') or 1) - 1
-      local icon, icon_hl
-      if m.status == 'done' then
-        icon, icon_hl = icons.done, 'PendingDone'
-      elseif m.priority and m.priority > 0 then
-        icon, icon_hl = icons.priority, 'PendingPriority'
-      else
-        icon, icon_hl = icons.pending, 'Normal'
-      end
-      vim.api.nvim_buf_set_extmark(bufnr, task_ns, row, bracket_col, {
-        virt_text = { { '[' .. icon .. ']', icon_hl } },
-        virt_text_pos = 'overlay',
-        priority = 100,
-      })
     elseif m.type == 'header' then
       local line = vim.api.nvim_buf_get_lines(bufnr, row, row + 1, false)[1] or ''
       vim.api.nvim_buf_set_extmark(bufnr, task_ns, row, 0, {
         end_col = #line,
         hl_group = 'PendingHeader',
       })
-      vim.api.nvim_buf_set_extmark(bufnr, task_ns, row, 0, {
-        virt_text = { { icons.category .. ' ', 'PendingHeader' } },
-        virt_text_pos = 'overlay',
-        priority = 100,
-      })
     end
   end
 end
@@ -231,8 +167,6 @@ local function setup_highlights()
   vim.api.nvim_set_hl(0, 'PendingOverdue', { link = 'DiagnosticError', default = true })
   vim.api.nvim_set_hl(0, 'PendingDone', { link = 'Comment', default = true })
   vim.api.nvim_set_hl(0, 'PendingPriority', { link = 'DiagnosticWarn', default = true })
-  vim.api.nvim_set_hl(0, 'PendingRecur', { link = 'DiagnosticInfo', default = true })
-  vim.api.nvim_set_hl(0, 'PendingFilter', { link = 'DiagnosticWarn', default = true })
 end
 
 local function snapshot_folds(bufnr)
@@ -278,7 +212,6 @@ local function restore_folds(bufnr)
 end
 
 ---@param bufnr? integer
----@return nil
 function M.render(bufnr)
   bufnr = bufnr or task_bufnr
   if not bufnr or not vim.api.nvim_buf_is_valid(bufnr) then
@@ -286,15 +219,8 @@ function M.render(bufnr)
   end
 
   current_view = current_view or config.get().default_view
-  local view_label = current_view == 'priority' and 'queue' or current_view
+  vim.api.nvim_buf_set_name(bufnr, 'pending://' .. current_view)
-  vim.api.nvim_buf_set_name(bufnr, 'pending://' .. view_label)
+  local tasks = store.active_tasks()
-  local all_tasks = _store and _store:active_tasks() or {}
-  local tasks = {}
-  for _, task in ipairs(all_tasks) do
-    if not _hidden_ids[task.id] then
-      table.insert(tasks, task)
-    end
-  end
 
   local lines, line_meta
   if current_view == 'priority' then
@@ -303,11 +229,6 @@ function M.render(bufnr)
     lines, line_meta = views.category_view(tasks)
   end
 
-  if #_filter_predicates > 0 then
-    table.insert(lines, 1, 'FILTER: ' .. table.concat(_filter_predicates, ' '))
-    table.insert(line_meta, 1, { type = 'filter' })
-  end
-
   _meta = line_meta
 
   snapshot_folds(bufnr)
@@ -335,7 +256,6 @@ function M.render(bufnr)
   restore_folds(bufnr)
 end
 
----@return nil
 function M.toggle_view()
   if current_view == 'category' then
     current_view = 'priority'
@@ -348,9 +268,7 @@ end
 ---@return integer bufnr
 function M.open()
   setup_highlights()
-  if _store then
+  store.load()
-    _store:load()
-  end
 
   if task_winid and vim.api.nvim_win_is_valid(task_winid) then
     vim.api.nvim_set_current_win(task_winid)

lua/pending/complete.lua

@@ -1,173 +0,0 @@
-local config = require('pending.config')
-
----@class pending.complete
-local M = {}
-
----@return string
-local function date_key()
-  return config.get().date_syntax or 'due'
-end
-
----@return string
-local function recur_key()
-  return config.get().recur_syntax or 'rec'
-end
-
----@return string[]
-local function get_categories()
-  local s = require('pending.buffer').store()
-  if not s then
-    return {}
-  end
-  local seen = {}
-  local result = {}
-  for _, task in ipairs(s:active_tasks()) do
-    local cat = task.category
-    if cat and not seen[cat] then
-      seen[cat] = true
-      table.insert(result, cat)
-    end
-  end
-  table.sort(result)
-  return result
-end
-
----@return { word: string, info: string }[]
-local function date_completions()
-  return {
-    { word = 'today', info = "Today's date" },
-    { word = 'tomorrow', info = "Tomorrow's date" },
-    { word = 'yesterday', info = "Yesterday's date" },
-    { word = '+1d', info = '1 day from today' },
-    { word = '+2d', info = '2 days from today' },
-    { word = '+3d', info = '3 days from today' },
-    { word = '+1w', info = '1 week from today' },
-    { word = '+2w', info = '2 weeks from today' },
-    { word = '+1m', info = '1 month from today' },
-    { word = 'mon', info = 'Next Monday' },
-    { word = 'tue', info = 'Next Tuesday' },
-    { word = 'wed', info = 'Next Wednesday' },
-    { word = 'thu', info = 'Next Thursday' },
-    { word = 'fri', info = 'Next Friday' },
-    { word = 'sat', info = 'Next Saturday' },
-    { word = 'sun', info = 'Next Sunday' },
-    { word = 'eod', info = 'End of day (today)' },
-    { word = 'eow', info = 'End of week (Sunday)' },
-    { word = 'eom', info = 'End of month' },
-    { word = 'eoq', info = 'End of quarter' },
-    { word = 'eoy', info = 'End of year (Dec 31)' },
-    { word = 'sow', info = 'Start of week (Monday)' },
-    { word = 'som', info = 'Start of month' },
-    { word = 'soq', info = 'Start of quarter' },
-    { word = 'soy', info = 'Start of year (Jan 1)' },
-    { word = 'later', info = 'Someday (sentinel date)' },
-    { word = 'today@08:00', info = 'Today at 08:00' },
-    { word = 'today@09:00', info = 'Today at 09:00' },
-    { word = 'today@10:00', info = 'Today at 10:00' },
-    { word = 'today@12:00', info = 'Today at 12:00' },
-    { word = 'today@14:00', info = 'Today at 14:00' },
-    { word = 'today@17:00', info = 'Today at 17:00' },
-  }
-end
-
----@type table<string, string>
-local recur_descriptions = {
-  daily = 'Every day',
-  weekdays = 'Monday through Friday',
-  weekly = 'Every week',
-  biweekly = 'Every 2 weeks',
-  monthly = 'Every month',
-  quarterly = 'Every 3 months',
-  yearly = 'Every year',
-  ['2d'] = 'Every 2 days',
-  ['3d'] = 'Every 3 days',
-  ['2w'] = 'Every 2 weeks',
-  ['3w'] = 'Every 3 weeks',
-  ['2m'] = 'Every 2 months',
-  ['3m'] = 'Every 3 months',
-  ['6m'] = 'Every 6 months',
-  ['2y'] = 'Every 2 years',
-}
-
----@return { word: string, info: string }[]
-local function recur_completions()
-  local recur = require('pending.recur')
-  local list = recur.shorthand_list()
-  local result = {}
-  for _, s in ipairs(list) do
-    local desc = recur_descriptions[s] or s
-    table.insert(result, { word = s, info = desc })
-  end
-  for _, s in ipairs(list) do
-    local desc = recur_descriptions[s] or s
-    table.insert(result, { word = '!' .. s, info = desc .. ' (from completion date)' })
-  end
-  return result
-end
-
----@type string?
-local _complete_source = nil
-
----@param findstart integer
----@param base string
----@return integer|table[]
-function M.omnifunc(findstart, base)
-  if findstart == 1 then
-    local line = vim.api.nvim_get_current_line()
-    local col = vim.api.nvim_win_get_cursor(0)[2]
-    local before = line:sub(1, col)
-
-    local dk = date_key()
-    local rk = recur_key()
-
-    local checks = {
-      { vim.pesc(dk) .. ':([%S]*)$', dk },
-      { 'cat:([%S]*)$', 'cat' },
-      { vim.pesc(rk) .. ':([%S]*)$', rk },
-    }
-
-    for _, check in ipairs(checks) do
-      local start = before:find(check[1])
-      if start then
-        local colon_pos = before:find(':', start, true)
-        if colon_pos then
-          _complete_source = check[2]
-          return colon_pos
-        end
-      end
-    end
-
-    _complete_source = nil
-    return -1
-  end
-
-  local matches = {}
-  local source = _complete_source or ''
-
-  local dk = date_key()
-  local rk = recur_key()
-
-  if source == dk then
-    for _, c in ipairs(date_completions()) do
-      if base == '' or c.word:sub(1, #base) == base then
-        table.insert(matches, { word = c.word, menu = '[' .. source .. ']', info = c.info })
-      end
-    end
-  elseif source == 'cat' then
-    for _, c in ipairs(get_categories()) do
-      if base == '' or c:sub(1, #base) == base then
-        table.insert(matches, { word = c, menu = '[cat]' })
-      end
-    end
-  elseif source == rk then
-    for _, c in ipairs(recur_completions()) do
-      if base == '' or c.word:sub(1, #base) == base then
-        table.insert(matches, { word = c.word, menu = '[' .. source .. ']', info = c.info })
-      end
-    end
-  end
-
-  return matches
-end
-
-return M

lua/pending/config.lua

@@ -1,43 +1,6 @@
----@class pending.Icons
----@field pending string
----@field done string
----@field priority string
----@field due string
----@field recur string
----@field category string
-
 ---@class pending.GcalConfig
+---@field calendar? string
 ---@field credentials_path? string
----@field client_id? string
----@field client_secret? string
-
----@class pending.GtasksConfig
----@field credentials_path? string
----@field client_id? string
----@field client_secret? string
-
----@class pending.SyncConfig
----@field gcal? pending.GcalConfig
----@field gtasks? pending.GtasksConfig
-
----@class pending.Keymaps
----@field close? string|false
----@field toggle? string|false
----@field view? string|false
----@field priority? string|false
----@field date? string|false
----@field undo? string|false
----@field filter? string|false
----@field open_line? string|false
----@field open_line_above? string|false
----@field a_task? string|false
----@field i_task? string|false
----@field a_category? string|false
----@field i_category? string|false
----@field next_header? string|false
----@field prev_header? string|false
----@field next_task? string|false
----@field prev_task? string|false
 
 ---@class pending.Config
 ---@field data_path string
@@ -45,15 +8,9 @@
 ---@field default_category string
 ---@field date_format string
 ---@field date_syntax string
----@field recur_syntax string
----@field someday_date string
----@field input_date_formats? string[]
 ---@field category_order? string[]
 ---@field drawer_height? integer
----@field debug? boolean
+---@field gcal? pending.GcalConfig
----@field keymaps pending.Keymaps
----@field sync? pending.SyncConfig
----@field icons pending.Icons
 
 ---@class pending.config
 local M = {}
@@ -65,37 +22,7 @@ local defaults = {
   default_category = 'Todo',
   date_format = '%b %d',
   date_syntax = 'due',
-  recur_syntax = 'rec',
-  someday_date = '9999-12-30',
   category_order = {},
-  keymaps = {
-    close = 'q',
-    toggle = '<CR>',
-    view = '<Tab>',
-    priority = '!',
-    date = 'D',
-    undo = 'U',
-    filter = 'F',
-    open_line = 'o',
-    open_line_above = 'O',
-    a_task = 'at',
-    i_task = 'it',
-    a_category = 'aC',
-    i_category = 'iC',
-    next_header = ']]',
-    prev_header = '[[',
-    next_task = ']t',
-    prev_task = '[t',
-  },
-  sync = {},
-  icons = {
-    pending = ' ',
-    done = 'x',
-    priority = '!',
-    due = '.',
-    recur = '~',
-    category = '#',
-  },
 }
 
 ---@type pending.Config?
@@ -111,7 +38,6 @@ function M.get()
   return _resolved
 end
 
----@return nil
 function M.reset()
   _resolved = nil
 end

lua/pending/diff.lua

@@ -1,5 +1,6 @@
 local config = require('pending.config')
 local parse = require('pending.parse')
+local store = require('pending.store')
 
 ---@class pending.ParsedEntry
 ---@field type 'task'|'header'|'blank'
@@ -9,8 +10,6 @@ local parse = require('pending.parse')
 ---@field status? string
 ---@field category? string
 ---@field due? string
----@field rec? string
----@field rec_mode? string
 ---@field lnum integer
 
 ---@class pending.diff
@@ -26,13 +25,8 @@ end
 function M.parse_buffer(lines)
   local result = {}
   local current_category = nil
-  local start = 1
-  if lines[1] and lines[1]:match('^FILTER:') then
-    start = 2
-  end
 
-  for i = start, #lines do
+  for i, line in ipairs(lines) do
-    local line = lines[i]
     local id, body = line:match('^/(%d+)/(- %[.%] .*)$')
     if not id then
       body = line:match('^(- %[.%] .*)$')
@@ -54,13 +48,11 @@ function M.parse_buffer(lines)
           status = status,
           category = metadata.cat or current_category or config.get().default_category,
           due = metadata.due,
-          rec = metadata.rec,
-          rec_mode = metadata.rec_mode,
           lnum = i,
         })
       end
-    elseif line:match('^# (.+)$') then
+    elseif line:match('^## (.+)$') then
-      current_category = line:match('^# (.+)$')
+      current_category = line:match('^## (.+)$')
       table.insert(result, { type = 'header', category = current_category, lnum = i })
     end
   end
@@ -69,13 +61,10 @@ function M.parse_buffer(lines)
 end
 
 ---@param lines string[]
----@param s pending.Store
+function M.apply(lines)
----@param hidden_ids? table<integer, true>
----@return nil
-function M.apply(lines, s, hidden_ids)
   local parsed = M.parse_buffer(lines)
   local now = timestamp()
-  local data = s:data()
+  local data = store.data()
 
   local old_by_id = {}
   for _, task in ipairs(data.tasks) do
@@ -96,13 +85,11 @@ function M.apply(lines, s, hidden_ids)
 
     if entry.id and old_by_id[entry.id] then
       if seen_ids[entry.id] then
-        s:add({
+        store.add({
           description = entry.description,
           category = entry.category,
           priority = entry.priority,
           due = entry.due,
-          recur = entry.rec,
-          recur_mode = entry.rec_mode,
           order = order_counter,
         })
       else
@@ -121,20 +108,10 @@ function M.apply(lines, s, hidden_ids)
           task.priority = entry.priority
           changed = true
         end
-        if entry.due ~= nil and task.due ~= entry.due then
+        if task.due ~= entry.due then
           task.due = entry.due
           changed = true
         end
-        if entry.rec ~= nil then
-          if task.recur ~= entry.rec then
-            task.recur = entry.rec
-            changed = true
-          end
-          if task.recur_mode ~= entry.rec_mode then
-            task.recur_mode = entry.rec_mode
-            changed = true
-          end
-        end
         if entry.status and task.status ~= entry.status then
           task.status = entry.status
           if entry.status == 'done' then
@@ -153,13 +130,11 @@ function M.apply(lines, s, hidden_ids)
         end
       end
     else
-      s:add({
+      store.add({
         description = entry.description,
         category = entry.category,
         priority = entry.priority,
         due = entry.due,
-        recur = entry.rec,
-        recur_mode = entry.rec_mode,
         order = order_counter,
       })
     end
@@ -168,14 +143,14 @@ function M.apply(lines, s, hidden_ids)
   end
 
   for id, task in pairs(old_by_id) do
-    if not seen_ids[id] and not (hidden_ids and hidden_ids[id]) then
+    if not seen_ids[id] then
       task.status = 'deleted'
       task['end'] = now
       task.modified = now
     end
   end
 
-  s:save()
+  store.save()
 end
 
 return M

lua/pending/health.lua

@@ -1,6 +1,5 @@
 local M = {}
 
----@return nil
 function M.check()
   vim.health.start('pending.nvim')
 
@@ -10,54 +9,42 @@ function M.check()
     return
   end
 
-  config.get()
+  local cfg = config.get()
   vim.health.ok('Config loaded')
+  vim.health.info('Data path: ' .. cfg.data_path)
 
-  local store_ok, store = pcall(require, 'pending.store')
+  local data_dir = vim.fn.fnamemodify(cfg.data_path, ':h')
-  if not store_ok then
+  if vim.fn.isdirectory(data_dir) == 1 then
-    vim.health.error('Failed to load pending.store')
+    vim.health.ok('Data directory exists: ' .. data_dir)
-    return
-  end
-
-  local resolved_path = store.resolve_path()
-  vim.health.info('Store path: ' .. resolved_path)
-
-  if vim.fn.filereadable(resolved_path) == 1 then
-    local s = store.new(resolved_path)
-    local load_ok, err = pcall(function()
-      s:load()
-    end)
-    if load_ok then
-      local tasks = s:tasks()
-      vim.health.ok('Data file loaded: ' .. #tasks .. ' tasks')
-      local recur = require('pending.recur')
-      local invalid_count = 0
-      for _, task in ipairs(tasks) do
-        if task.recur and not recur.validate(task.recur) then
-          invalid_count = invalid_count + 1
-          vim.health.warn('Task ' .. task.id .. ' has invalid recurrence spec: ' .. task.recur)
-        end
-      end
-      if invalid_count == 0 then
-        vim.health.ok('All recurrence specs are valid')
-      end
-    else
-      vim.health.error('Failed to load data file: ' .. tostring(err))
-    end
-  end
-
-  local sync_paths = vim.fn.globpath(vim.o.runtimepath, 'lua/pending/sync/*.lua', false, true)
-  if #sync_paths == 0 then
-    vim.health.info('No sync backends found')
   else
-    for _, path in ipairs(sync_paths) do
+    vim.health.warn('Data directory does not exist yet: ' .. data_dir)
-      local name = vim.fn.fnamemodify(path, ':t:r')
+  end
-      local bok, backend = pcall(require, 'pending.sync.' .. name)
+
-      if bok and backend.name and type(backend.health) == 'function' then
+  if vim.fn.filereadable(cfg.data_path) == 1 then
-        vim.health.start('pending.nvim: sync/' .. name)
+    local store_ok, store = pcall(require, 'pending.store')
-        backend.health()
+    if store_ok then
+      local load_ok, err = pcall(store.load)
+      if load_ok then
+        local tasks = store.tasks()
+        vim.health.ok('Data file loaded: ' .. #tasks .. ' tasks')
+      else
+        vim.health.error('Failed to load data file: ' .. tostring(err))
       end
     end
+  else
+    vim.health.info('No data file yet (will be created on first save)')
+  end
+
+  if vim.fn.executable('curl') == 1 then
+    vim.health.ok('curl found (required for Google Calendar sync)')
+  else
+    vim.health.warn('curl not found (needed for Google Calendar sync)')
+  end
+
+  if vim.fn.executable('openssl') == 1 then
+    vim.health.ok('openssl found (required for OAuth PKCE)')
+  else
+    vim.health.warn('openssl not found (needed for Google Calendar OAuth)')
   end
 end
 

lua/pending/log.lua

@@ -1,30 +0,0 @@
----@class pending.log
-local M = {}
-
-local PREFIX = '[pending.nvim]: '
-
----@param msg string
-function M.info(msg)
-  vim.notify(PREFIX .. msg)
-end
-
----@param msg string
-function M.warn(msg)
-  vim.notify(PREFIX .. msg, vim.log.levels.WARN)
-end
-
----@param msg string
-function M.error(msg)
-  vim.notify(PREFIX .. msg, vim.log.levels.ERROR)
-end
-
----@param msg string
----@param override? boolean
-function M.debug(msg, override)
-  local cfg = require('pending.config').get()
-  if cfg.debug or override then
-    vim.notify(PREFIX .. msg, vim.log.levels.DEBUG)
-  end
-end
-
-return M

lua/pending/parse.lua

@@ -24,92 +24,11 @@ local function is_valid_date(s)
   return check.year == yn and check.month == mn and check.day == dn
 end
 
----@param s string
----@return boolean
-local function is_valid_time(s)
-  local h, m = s:match('^(%d%d):(%d%d)$')
-  if not h then
-    return false
-  end
-  local hn = tonumber(h) --[[@as integer]]
-  local mn = tonumber(m) --[[@as integer]]
-  return hn >= 0 and hn <= 23 and mn >= 0 and mn <= 59
-end
-
----@param s string
----@return string|nil
-local function normalize_time(s)
-  local h, m, period
-
-  h, m, period = s:match('^(%d+):(%d%d)([ap]m)$')
-  if not h then
-    h, period = s:match('^(%d+)([ap]m)$')
-    if h then
-      m = '00'
-    end
-  end
-  if not h then
-    h, m = s:match('^(%d%d):(%d%d)$')
-  end
-  if not h then
-    h, m = s:match('^(%d):(%d%d)$')
-  end
-  if not h then
-    h = s:match('^(%d+)$')
-    if h then
-      m = '00'
-    end
-  end
-
-  if not h then
-    return nil
-  end
-
-  local hn = tonumber(h) --[[@as integer]]
-  local mn = tonumber(m) --[[@as integer]]
-
-  if period then
-    if hn < 1 or hn > 12 then
-      return nil
-    end
-    if period == 'am' then
-      hn = hn == 12 and 0 or hn
-    else
-      hn = hn == 12 and 12 or hn + 12
-    end
-  else
-    if hn < 0 or hn > 23 then
-      return nil
-    end
-  end
-
-  if mn < 0 or mn > 59 then
-    return nil
-  end
-
-  return string.format('%02d:%02d', hn, mn)
-end
-
----@param s string
----@return boolean
-local function is_valid_datetime(s)
-  local date_part, time_part = s:match('^(.+)T(.+)$')
-  if not date_part then
-    return is_valid_date(s)
-  end
-  return is_valid_date(date_part) and is_valid_time(time_part)
-end
-
 ---@return string
 local function date_key()
   return config.get().date_syntax or 'due'
 end
 
----@return string
-local function recur_key()
-  return config.get().recur_syntax or 'rec'
-end
-
 local weekday_map = {
   sun = 1,
   mon = 2,
@@ -120,402 +39,53 @@ local weekday_map = {
   sat = 7,
 }
 
-local month_map = {
-  jan = 1,
-  feb = 2,
-  mar = 3,
-  apr = 4,
-  may = 5,
-  jun = 6,
-  jul = 7,
-  aug = 8,
-  sep = 9,
-  oct = 10,
-  nov = 11,
-  dec = 12,
-}
-
----@param today osdate
----@return string
-local function today_str(today)
-  return os.date('%Y-%m-%d', os.time({ year = today.year, month = today.month, day = today.day })) --[[@as string]]
-end
-
----@param date_part string
----@param time_suffix? string
----@return string
-local function append_time(date_part, time_suffix)
-  if time_suffix then
-    return date_part .. 'T' .. time_suffix
-  end
-  return date_part
-end
-
----@param name string
----@return integer?
-local function month_name_to_num(name)
-  return month_map[name:lower():sub(1, 3)]
-end
-
----@param fmt string
----@return string, string[]
-local function input_format_to_pattern(fmt)
-  local fields = {}
-  local parts = {}
-  local i = 1
-  while i <= #fmt do
-    local c = fmt:sub(i, i)
-    if c == '%' and i < #fmt then
-      local spec = fmt:sub(i + 1, i + 1)
-      if spec == '%' then
-        parts[#parts + 1] = '%%'
-        i = i + 2
-      elseif spec == 'Y' then
-        fields[#fields + 1] = 'year'
-        parts[#parts + 1] = '(%d%d%d%d)'
-        i = i + 2
-      elseif spec == 'y' then
-        fields[#fields + 1] = 'year2'
-        parts[#parts + 1] = '(%d%d)'
-        i = i + 2
-      elseif spec == 'm' then
-        fields[#fields + 1] = 'month_num'
-        parts[#parts + 1] = '(%d%d?)'
-        i = i + 2
-      elseif spec == 'd' or spec == 'e' then
-        fields[#fields + 1] = 'day'
-        parts[#parts + 1] = '(%d%d?)'
-        i = i + 2
-      elseif spec == 'b' or spec == 'B' then
-        fields[#fields + 1] = 'month_name'
-        parts[#parts + 1] = '(%a+)'
-        i = i + 2
-      else
-        parts[#parts + 1] = vim.pesc(c)
-        i = i + 1
-      end
-    else
-      parts[#parts + 1] = vim.pesc(c)
-      i = i + 1
-    end
-  end
-  return '^' .. table.concat(parts) .. '$', fields
-end
-
----@param date_input string
----@param time_suffix? string
----@return string?
-local function try_input_date_formats(date_input, time_suffix)
-  local fmts = config.get().input_date_formats
-  if not fmts or #fmts == 0 then
-    return nil
-  end
-  local today = os.date('*t') --[[@as osdate]]
-  for _, fmt in ipairs(fmts) do
-    local pat, fields = input_format_to_pattern(fmt)
-    local caps = { date_input:match(pat) }
-    if caps[1] ~= nil then
-      local year, month, day
-      for j = 1, #fields do
-        local field = fields[j]
-        local val = caps[j]
-        if field == 'year' then
-          year = tonumber(val)
-        elseif field == 'year2' then
-          local y = tonumber(val) --[[@as integer]]
-          year = y + (y >= 70 and 1900 or 2000)
-        elseif field == 'month_num' then
-          month = tonumber(val)
-        elseif field == 'day' then
-          day = tonumber(val)
-        elseif field == 'month_name' then
-          month = month_name_to_num(val)
-        end
-      end
-      if month and day then
-        if not year then
-          year = today.year
-          if month < today.month or (month == today.month and day < today.day) then
-            year = year + 1
-          end
-        end
-        local t = os.time({ year = year, month = month, day = day })
-        local check = os.date('*t', t) --[[@as osdate]]
-        if check.year == year and check.month == month and check.day == day then
-          return append_time(os.date('%Y-%m-%d', t) --[[@as string]], time_suffix)
-        end
-      end
-    end
-  end
-  return nil
-end
-
 ---@param text string
 ---@return string|nil
 function M.resolve_date(text)
-  local date_input, time_suffix = text:match('^(.+)@(.+)$')
+  local lower = text:lower()
-  if time_suffix then
-    time_suffix = normalize_time(time_suffix)
-    if not time_suffix then
-      return nil
-    end
-  else
-    date_input = text
-  end
-
-  local dt = date_input:match('^(%d%d%d%d%-%d%d%-%d%dT%d%d:%d%d)$')
-  if dt then
-    local dp, tp = dt:match('^(.+)T(.+)$')
-    if is_valid_date(dp) and is_valid_time(tp) then
-      return dt
-    end
-    return nil
-  end
-
-  if is_valid_date(date_input) then
-    return append_time(date_input, time_suffix)
-  end
-
-  local lower = date_input:lower()
   local today = os.date('*t') --[[@as osdate]]
 
-  if lower == 'today' or lower == 'eod' then
+  if lower == 'today' then
-    return append_time(today_str(today), time_suffix)
+    return os.date('%Y-%m-%d', os.time({ year = today.year, month = today.month, day = today.day })) --[[@as string]]
-  end
-
-  if lower == 'yesterday' then
-    return append_time(
-      os.date('%Y-%m-%d', os.time({ year = today.year, month = today.month, day = today.day - 1 })) --[[@as string]],
-      time_suffix
-    )
   end
 
   if lower == 'tomorrow' then
-    return append_time(
+    return os.date(
-      os.date('%Y-%m-%d', os.time({ year = today.year, month = today.month, day = today.day + 1 })) --[[@as string]],
+      '%Y-%m-%d',
-      time_suffix
+      os.time({ year = today.year, month = today.month, day = today.day + 1 })
-    )
+    ) --[[@as string]]
-  end
-
-  if lower == 'sow' then
-    local delta = -((today.wday - 2) % 7)
-    return append_time(
-      os.date(
-        '%Y-%m-%d',
-        os.time({ year = today.year, month = today.month, day = today.day + delta })
-      ) --[[@as string]],
-      time_suffix
-    )
-  end
-
-  if lower == 'eow' then
-    local delta = (1 - today.wday) % 7
-    return append_time(
-      os.date(
-        '%Y-%m-%d',
-        os.time({ year = today.year, month = today.month, day = today.day + delta })
-      ) --[[@as string]],
-      time_suffix
-    )
-  end
-
-  if lower == 'som' then
-    return append_time(
-      os.date('%Y-%m-%d', os.time({ year = today.year, month = today.month, day = 1 })) --[[@as string]],
-      time_suffix
-    )
-  end
-
-  if lower == 'eom' then
-    return append_time(
-      os.date('%Y-%m-%d', os.time({ year = today.year, month = today.month + 1, day = 0 })) --[[@as string]],
-      time_suffix
-    )
-  end
-
-  if lower == 'soq' then
-    local q = math.ceil(today.month / 3)
-    local first_month = (q - 1) * 3 + 1
-    return append_time(
-      os.date('%Y-%m-%d', os.time({ year = today.year, month = first_month, day = 1 })) --[[@as string]],
-      time_suffix
-    )
-  end
-
-  if lower == 'eoq' then
-    local q = math.ceil(today.month / 3)
-    local last_month = q * 3
-    return append_time(
-      os.date('%Y-%m-%d', os.time({ year = today.year, month = last_month + 1, day = 0 })) --[[@as string]],
-      time_suffix
-    )
-  end
-
-  if lower == 'soy' then
-    return append_time(
-      os.date('%Y-%m-%d', os.time({ year = today.year, month = 1, day = 1 })) --[[@as string]],
-      time_suffix
-    )
-  end
-
-  if lower == 'eoy' then
-    return append_time(
-      os.date('%Y-%m-%d', os.time({ year = today.year, month = 12, day = 31 })) --[[@as string]],
-      time_suffix
-    )
-  end
-
-  if lower == 'later' or lower == 'someday' then
-    return append_time(config.get().someday_date, time_suffix)
   end
 
   local n = lower:match('^%+(%d+)d$')
   if n then
-    return append_time(
+    return os.date(
-      os.date(
+      '%Y-%m-%d',
-        '%Y-%m-%d',
+      os.time({
-        os.time({
+        year = today.year,
-          year = today.year,
+        month = today.month,
-          month = today.month,
+        day = today.day + (
-          day = today.day + (
+            tonumber(n) --[[@as integer]]
-              tonumber(n) --[[@as integer]]
+          ),
-            ),
+      })
-        })
+    ) --[[@as string]]
-      ) --[[@as string]],
-      time_suffix
-    )
-  end
-
-  n = lower:match('^%+(%d+)w$')
-  if n then
-    return append_time(
-      os.date(
-        '%Y-%m-%d',
-        os.time({
-          year = today.year,
-          month = today.month,
-          day = today.day + (
-              tonumber(n) --[[@as integer]]
-            ) * 7,
-        })
-      ) --[[@as string]],
-      time_suffix
-    )
-  end
-
-  n = lower:match('^%+(%d+)m$')
-  if n then
-    return append_time(
-      os.date(
-        '%Y-%m-%d',
-        os.time({
-          year = today.year,
-          month = today.month + (
-              tonumber(n) --[[@as integer]]
-            ),
-          day = today.day,
-        })
-      ) --[[@as string]],
-      time_suffix
-    )
-  end
-
-  n = lower:match('^%-(%d+)d$')
-  if n then
-    return append_time(
-      os.date(
-        '%Y-%m-%d',
-        os.time({
-          year = today.year,
-          month = today.month,
-          day = today.day - (
-              tonumber(n) --[[@as integer]]
-            ),
-        })
-      ) --[[@as string]],
-      time_suffix
-    )
-  end
-
-  n = lower:match('^%-(%d+)w$')
-  if n then
-    return append_time(
-      os.date(
-        '%Y-%m-%d',
-        os.time({
-          year = today.year,
-          month = today.month,
-          day = today.day - (
-              tonumber(n) --[[@as integer]]
-            ) * 7,
-        })
-      ) --[[@as string]],
-      time_suffix
-    )
-  end
-
-  local ord = lower:match('^(%d+)[snrt][tdh]$')
-  if ord then
-    local day_num = tonumber(ord) --[[@as integer]]
-    if day_num >= 1 and day_num <= 31 then
-      local m, y = today.month, today.year
-      if today.day >= day_num then
-        m = m + 1
-        if m > 12 then
-          m = 1
-          y = y + 1
-        end
-      end
-      local t = os.time({ year = y, month = m, day = day_num })
-      local check = os.date('*t', t) --[[@as osdate]]
-      if check.day == day_num then
-        return append_time(os.date('%Y-%m-%d', t) --[[@as string]], time_suffix)
-      end
-      m = m + 1
-      if m > 12 then
-        m = 1
-        y = y + 1
-      end
-      t = os.time({ year = y, month = m, day = day_num })
-      check = os.date('*t', t) --[[@as osdate]]
-      if check.day == day_num then
-        return append_time(os.date('%Y-%m-%d', t) --[[@as string]], time_suffix)
-      end
-      return nil
-    end
-  end
-
-  local target_month = month_map[lower]
-  if target_month then
-    local y = today.year
-    if today.month >= target_month then
-      y = y + 1
-    end
-    return append_time(
-      os.date('%Y-%m-%d', os.time({ year = y, month = target_month, day = 1 })) --[[@as string]],
-      time_suffix
-    )
   end
 
   local target_wday = weekday_map[lower]
   if target_wday then
     local current_wday = today.wday
     local delta = (target_wday - current_wday) % 7
-    return append_time(
+    return os.date(
-      os.date(
+      '%Y-%m-%d',
-        '%Y-%m-%d',
+      os.time({ year = today.year, month = today.month, day = today.day + delta })
-        os.time({ year = today.year, month = today.month, day = today.day + delta })
+    ) --[[@as string]]
-      ) --[[@as string]],
-      time_suffix
-    )
   end
 
-  return try_input_date_formats(date_input, time_suffix)
+  return nil
 end
 
 ---@param text string
 ---@return string description
----@return { due?: string, cat?: string, rec?: string, rec_mode?: 'scheduled'|'completion' } metadata
+---@return { due?: string, cat?: string } metadata
 function M.body(text)
   local tokens = {}
   for token in text:gmatch('%S+') do
@@ -525,10 +95,8 @@ function M.body(text)
   local metadata = {}
   local i = #tokens
   local dk = date_key()
-  local rk = recur_key()
+  local date_pattern_strict = '^' .. vim.pesc(dk) .. ':(%d%d%d%d%-%d%d%-%d%d)$'
-  local date_pattern_strict = '^' .. vim.pesc(dk) .. ':(%d%d%d%d%-%d%d%-%d%d[T%d:]*)$'
   local date_pattern_any = '^' .. vim.pesc(dk) .. ':(.+)$'
-  local rec_pattern = '^' .. vim.pesc(rk) .. ':(%S+)$'
 
   while i >= 1 do
     local token = tokens[i]
@@ -537,7 +105,7 @@ function M.body(text)
       if metadata.due then
         break
       end
-      if not is_valid_datetime(due_val) then
+      if not is_valid_date(due_val) then
         break
       end
       metadata.due = due_val
@@ -563,25 +131,7 @@ function M.body(text)
           metadata.cat = cat_val
           i = i - 1
         else
-          local rec_val = token:match(rec_pattern)
+          break
-          if rec_val then
-            if metadata.rec then
-              break
-            end
-            local recur = require('pending.recur')
-            local raw_spec = rec_val
-            if raw_spec:sub(1, 1) == '!' then
-              metadata.rec_mode = 'completion'
-              raw_spec = raw_spec:sub(2)
-            end
-            if not recur.validate(raw_spec) then
-              break
-            end
-            metadata.rec = raw_spec
-            i = i - 1
-          else
-            break
-          end
         end
       end
     end
@@ -598,7 +148,7 @@ end
 
 ---@param text string
 ---@return string description
----@return { due?: string, cat?: string, rec?: string, rec_mode?: 'scheduled'|'completion' } metadata
+---@return { due?: string, cat?: string } metadata
 function M.command_add(text)
   local cat_prefix = text:match('^(%S.-):%s')
   if cat_prefix then
@@ -615,39 +165,4 @@ function M.command_add(text)
   return M.body(text)
 end
 
----@param due string
----@return boolean
-function M.is_overdue(due)
-  local now = os.date('*t') --[[@as osdate]]
-  local today = os.date('%Y-%m-%d') --[[@as string]]
-  local date_part, time_part = due:match('^(.+)T(.+)$')
-  if not date_part then
-    return due < today
-  end
-  if date_part < today then
-    return true
-  end
-  if date_part > today then
-    return false
-  end
-  local current_time = string.format('%02d:%02d', now.hour, now.min)
-  return time_part < current_time
-end
-
----@param due string
----@return boolean
-function M.is_today(due)
-  local now = os.date('*t') --[[@as osdate]]
-  local today = os.date('%Y-%m-%d') --[[@as string]]
-  local date_part, time_part = due:match('^(.+)T(.+)$')
-  if not date_part then
-    return due == today
-  end
-  if date_part ~= today then
-    return false
-  end
-  local current_time = string.format('%02d:%02d', now.hour, now.min)
-  return time_part >= current_time
-end
-
 return M

lua/pending/recur.lua

@@ -1,188 +0,0 @@
----@class pending.RecurSpec
----@field freq 'daily'|'weekly'|'monthly'|'yearly'
----@field interval integer
----@field byday? string[]
----@field from_completion boolean
----@field _raw? string
-
----@class pending.recur
-local M = {}
-
----@type table<string, pending.RecurSpec>
-local named = {
-  daily = { freq = 'daily', interval = 1, from_completion = false },
-  weekdays = {
-    freq = 'weekly',
-    interval = 1,
-    byday = { 'MO', 'TU', 'WE', 'TH', 'FR' },
-    from_completion = false,
-  },
-  weekly = { freq = 'weekly', interval = 1, from_completion = false },
-  biweekly = { freq = 'weekly', interval = 2, from_completion = false },
-  monthly = { freq = 'monthly', interval = 1, from_completion = false },
-  quarterly = { freq = 'monthly', interval = 3, from_completion = false },
-  yearly = { freq = 'yearly', interval = 1, from_completion = false },
-  annual = { freq = 'yearly', interval = 1, from_completion = false },
-}
-
----@param spec string
----@return pending.RecurSpec?
-function M.parse(spec)
-  local from_completion = false
-  local s = spec
-
-  if s:sub(1, 1) == '!' then
-    from_completion = true
-    s = s:sub(2)
-  end
-
-  local lower = s:lower()
-
-  local base = named[lower]
-  if base then
-    return {
-      freq = base.freq,
-      interval = base.interval,
-      byday = base.byday,
-      from_completion = from_completion,
-    }
-  end
-
-  local n, unit = lower:match('^(%d+)([dwmy])$')
-  if n then
-    local num = tonumber(n) --[[@as integer]]
-    if num < 1 then
-      return nil
-    end
-    local freq_map = { d = 'daily', w = 'weekly', m = 'monthly', y = 'yearly' }
-    return {
-      freq = freq_map[unit],
-      interval = num,
-      from_completion = from_completion,
-    }
-  end
-
-  if s:match('^FREQ=') then
-    return {
-      freq = 'daily',
-      interval = 1,
-      from_completion = from_completion,
-      _raw = s,
-    }
-  end
-
-  return nil
-end
-
----@param spec string
----@return boolean
-function M.validate(spec)
-  return M.parse(spec) ~= nil
-end
-
----@param due string
----@return string date_part
----@return string? time_part
-local function split_datetime(due)
-  local dp, tp = due:match('^(.+)T(.+)$')
-  if dp then
-    return dp, tp
-  end
-  return due, nil
-end
-
----@param base_date string
----@param freq string
----@param interval integer
----@return string
-local function advance_date(base_date, freq, interval)
-  local date_part, time_part = split_datetime(base_date)
-  local y, m, d = date_part:match('^(%d+)-(%d+)-(%d+)$')
-  local yn = tonumber(y) --[[@as integer]]
-  local mn = tonumber(m) --[[@as integer]]
-  local dn = tonumber(d) --[[@as integer]]
-
-  local result
-  if freq == 'daily' then
-    result = os.date('%Y-%m-%d', os.time({ year = yn, month = mn, day = dn + interval })) --[[@as string]]
-  elseif freq == 'weekly' then
-    result = os.date('%Y-%m-%d', os.time({ year = yn, month = mn, day = dn + interval * 7 })) --[[@as string]]
-  elseif freq == 'monthly' then
-    local new_m = mn + interval
-    local new_y = yn
-    while new_m > 12 do
-      new_m = new_m - 12
-      new_y = new_y + 1
-    end
-    local last_day = os.date('*t', os.time({ year = new_y, month = new_m + 1, day = 0 })) --[[@as osdate]]
-    local clamped_d = math.min(dn, last_day.day --[[@as integer]])
-    result = os.date('%Y-%m-%d', os.time({ year = new_y, month = new_m, day = clamped_d })) --[[@as string]]
-  elseif freq == 'yearly' then
-    local new_y = yn + interval
-    local last_day = os.date('*t', os.time({ year = new_y, month = mn + 1, day = 0 })) --[[@as osdate]]
-    local clamped_d = math.min(dn, last_day.day --[[@as integer]])
-    result = os.date('%Y-%m-%d', os.time({ year = new_y, month = mn, day = clamped_d })) --[[@as string]]
-  else
-    return base_date
-  end
-
-  if time_part then
-    return result .. 'T' .. time_part
-  end
-  return result
-end
-
----@param base_date string
----@param spec string
----@param mode 'scheduled'|'completion'
----@return string
-function M.next_due(base_date, spec, mode)
-  local parsed = M.parse(spec)
-  if not parsed then
-    return base_date
-  end
-
-  local today = os.date('%Y-%m-%d') --[[@as string]]
-  local _, time_part = split_datetime(base_date)
-
-  if mode == 'completion' then
-    local base = time_part and (today .. 'T' .. time_part) or today
-    return advance_date(base, parsed.freq, parsed.interval)
-  end
-
-  local next_date = advance_date(base_date, parsed.freq, parsed.interval)
-  local compare_today = time_part and (today .. 'T' .. time_part) or today
-  while next_date <= compare_today do
-    next_date = advance_date(next_date, parsed.freq, parsed.interval)
-  end
-  return next_date
-end
-
----@param spec string
----@return string
-function M.to_rrule(spec)
-  local parsed = M.parse(spec)
-  if not parsed then
-    return ''
-  end
-
-  if parsed._raw then
-    return 'RRULE:' .. parsed._raw
-  end
-
-  local parts = { 'FREQ=' .. parsed.freq:upper() }
-  if parsed.interval > 1 then
-    table.insert(parts, 'INTERVAL=' .. parsed.interval)
-  end
-  if parsed.byday then
-    table.insert(parts, 'BYDAY=' .. table.concat(parsed.byday, ','))
-  end
-  return 'RRULE:' .. table.concat(parts, ';')
-end
-
----@return string[]
-function M.shorthand_list()
-  return { 'daily', 'weekdays', 'weekly', 'biweekly', 'monthly', 'quarterly', 'yearly', 'annual' }
-end
-
-return M

lua/pending/store.lua

@@ -7,8 +7,6 @@ local config = require('pending.config')
 ---@field category? string
 ---@field priority integer
 ---@field due? string
----@field recur? string
----@field recur_mode? 'scheduled'|'completion'
 ---@field entry string
 ---@field modified string
 ---@field end? string
@@ -19,26 +17,21 @@ local config = require('pending.config')
 ---@field version integer
 ---@field next_id integer
 ---@field tasks pending.Task[]
----@field undo pending.Task[][]
-
----@class pending.Store
----@field path string
----@field _data pending.Data?
-local Store = {}
-Store.__index = Store
 
 ---@class pending.store
 local M = {}
 
 local SUPPORTED_VERSION = 1
 
+---@type pending.Data?
+local _data = nil
+
 ---@return pending.Data
 local function empty_data()
   return {
     version = SUPPORTED_VERSION,
     next_id = 1,
     tasks = {},
-    undo = {},
   }
 end
 
@@ -63,8 +56,6 @@ local known_fields = {
   category = true,
   priority = true,
   due = true,
-  recur = true,
-  recur_mode = true,
   entry = true,
   modified = true,
   ['end'] = true,
@@ -90,12 +81,6 @@ local function task_to_table(task)
   if task.due then
     t.due = task.due
   end
-  if task.recur then
-    t.recur = task.recur
-  end
-  if task.recur_mode then
-    t.recur_mode = task.recur_mode
-  end
   if task['end'] then
     t['end'] = task['end']
   end
@@ -120,8 +105,6 @@ local function table_to_task(t)
     category = t.category,
     priority = t.priority or 0,
     due = t.due,
-    recur = t.recur,
-    recur_mode = t.recur_mode,
     entry = t.entry,
     modified = t.modified,
     ['end'] = t['end'],
@@ -140,18 +123,18 @@ local function table_to_task(t)
 end
 
 ---@return pending.Data
-function Store:load()
+function M.load()
-  local path = self.path
+  local path = config.get().data_path
   local f = io.open(path, 'r')
   if not f then
-    self._data = empty_data()
+    _data = empty_data()
-    return self._data
+    return _data
   end
   local content = f:read('*a')
   f:close()
   if content == '' then
-    self._data = empty_data()
+    _data = empty_data()
-    return self._data
+    return _data
   end
   local ok, decoded = pcall(vim.json.decode, content)
   if not ok then
@@ -166,50 +149,31 @@ function Store:load()
         .. '. Please update the plugin.'
     )
   end
-  self._data = {
+  _data = {
     version = decoded.version or SUPPORTED_VERSION,
     next_id = decoded.next_id or 1,
     tasks = {},
-    undo = {},
   }
   for _, t in ipairs(decoded.tasks or {}) do
-    table.insert(self._data.tasks, table_to_task(t))
+    table.insert(_data.tasks, table_to_task(t))
   end
-  for _, snapshot in ipairs(decoded.undo or {}) do
+  return _data
-    if type(snapshot) == 'table' then
-      local tasks = {}
-      for _, raw in ipairs(snapshot) do
-        table.insert(tasks, table_to_task(raw))
-      end
-      table.insert(self._data.undo, tasks)
-    end
-  end
-  return self._data
 end
 
----@return nil
+function M.save()
-function Store:save()
+  if not _data then
-  if not self._data then
     return
   end
-  local path = self.path
+  local path = config.get().data_path
   ensure_dir(path)
   local out = {
-    version = self._data.version,
+    version = _data.version,
-    next_id = self._data.next_id,
+    next_id = _data.next_id,
     tasks = {},
-    undo = {},
   }
-  for _, task in ipairs(self._data.tasks) do
+  for _, task in ipairs(_data.tasks) do
     table.insert(out.tasks, task_to_table(task))
   end
-  for _, snapshot in ipairs(self._data.undo) do
-    local serialized = {}
-    for _, task in ipairs(snapshot) do
-      table.insert(serialized, task_to_table(task))
-    end
-    table.insert(out.undo, serialized)
-  end
   local encoded = vim.json.encode(out)
   local tmp = path .. '.tmp'
   local f = io.open(tmp, 'w')
@@ -226,22 +190,22 @@ function Store:save()
 end
 
 ---@return pending.Data
-function Store:data()
+function M.data()
-  if not self._data then
+  if not _data then
-    self:load()
+    M.load()
   end
-  return self._data --[[@as pending.Data]]
+  return _data --[[@as pending.Data]]
 end
 
 ---@return pending.Task[]
-function Store:tasks()
+function M.tasks()
-  return self:data().tasks
+  return M.data().tasks
 end
 
 ---@return pending.Task[]
-function Store:active_tasks()
+function M.active_tasks()
   local result = {}
-  for _, task in ipairs(self:tasks()) do
+  for _, task in ipairs(M.tasks()) do
     if task.status ~= 'deleted' then
       table.insert(result, task)
     end
@@ -251,8 +215,8 @@ end
 
 ---@param id integer
 ---@return pending.Task?
-function Store:get(id)
+function M.get(id)
-  for _, task in ipairs(self:tasks()) do
+  for _, task in ipairs(M.tasks()) do
     if task.id == id then
       return task
     end
@@ -260,10 +224,10 @@ function Store:get(id)
   return nil
 end
 
----@param fields { description: string, status?: string, category?: string, priority?: integer, due?: string, recur?: string, recur_mode?: string, order?: integer, _extra?: table }
+---@param fields { description: string, status?: string, category?: string, priority?: integer, due?: string, order?: integer, _extra?: table }
 ---@return pending.Task
-function Store:add(fields)
+function M.add(fields)
-  local data = self:data()
+  local data = M.data()
   local now = timestamp()
   local task = {
     id = data.next_id,
@@ -272,8 +236,6 @@ function Store:add(fields)
     category = fields.category or config.get().default_category,
     priority = fields.priority or 0,
     due = fields.due,
-    recur = fields.recur,
-    recur_mode = fields.recur_mode,
     entry = now,
     modified = now,
     ['end'] = nil,
@@ -288,19 +250,15 @@ end
 ---@param id integer
 ---@param fields table<string, any>
 ---@return pending.Task?
-function Store:update(id, fields)
+function M.update(id, fields)
-  local task = self:get(id)
+  local task = M.get(id)
   if not task then
     return nil
   end
   local now = timestamp()
   for k, v in pairs(fields) do
     if k ~= 'id' and k ~= 'entry' then
-      if v == vim.NIL then
+      task[k] = v
-        task[k] = nil
-      else
-        task[k] = v
-      end
     end
   end
   task.modified = now
@@ -312,14 +270,14 @@ end
 
 ---@param id integer
 ---@return pending.Task?
-function Store:delete(id)
+function M.delete(id)
-  return self:update(id, { status = 'deleted', ['end'] = timestamp() })
+  return M.update(id, { status = 'deleted', ['end'] = timestamp() })
 end
 
 ---@param id integer
 ---@return integer?
-function Store:find_index(id)
+function M.find_index(id)
-  for i, task in ipairs(self:tasks()) do
+  for i, task in ipairs(M.tasks()) do
     if task.id == id then
       return i
     end
@@ -328,15 +286,14 @@ function Store:find_index(id)
 end
 
 ---@param tasks pending.Task[]
----@return nil
+function M.replace_tasks(tasks)
-function Store:replace_tasks(tasks)
+  M.data().tasks = tasks
-  self:data().tasks = tasks
 end
 
 ---@return pending.Task[]
-function Store:snapshot()
+function M.snapshot()
   local result = {}
-  for _, task in ipairs(self:active_tasks()) do
+  for _, task in ipairs(M.active_tasks()) do
     local copy = {}
     for k, v in pairs(task) do
       if k ~= '_extra' then
@@ -354,37 +311,13 @@ function Store:snapshot()
   return result
 end
 
----@return pending.Task[][]
-function Store:undo_stack()
-  return self:data().undo
-end
-
----@param stack pending.Task[][]
----@return nil
-function Store:set_undo_stack(stack)
-  self:data().undo = stack
-end
-
 ---@param id integer
----@return nil
+function M.set_next_id(id)
-function Store:set_next_id(id)
+  M.data().next_id = id
-  self:data().next_id = id
 end
 
----@return nil
+function M.unload()
-function Store:unload()
+  _data = nil
-  self._data = nil
-end
-
----@param path string
----@return pending.Store
-function M.new(path)
-  return setmetatable({ path = path, _data = nil }, Store)
-end
-
----@return string
-function M.resolve_path()
-  return config.get().data_path
 end
 
 return M

lua/pending/sync/gcal.lua

@@ -1,60 +1,384 @@
 local config = require('pending.config')
-local log = require('pending.log')
+local store = require('pending.store')
-local oauth = require('pending.sync.oauth')
 
 local M = {}
 
-M.name = 'gcal'
-
 local BASE_URL = 'https://www.googleapis.com/calendar/v3'
+local TOKEN_URL = 'https://oauth2.googleapis.com/token'
+local AUTH_URL = 'https://accounts.google.com/o/oauth2/v2/auth'
+local SCOPE = 'https://www.googleapis.com/auth/calendar'
 
----@param access_token string
+---@class pending.GcalCredentials
----@return table<string, string>? name_to_id
+---@field client_id string
----@return string? err
+---@field client_secret string
-local function get_all_calendars(access_token)
+---@field redirect_uris? string[]
-  local data, err = oauth.curl_request(
+
-    'GET',
+---@class pending.GcalTokens
-    BASE_URL .. '/users/me/calendarList',
+---@field access_token string
-    oauth.auth_headers(access_token)
+---@field refresh_token string
+---@field expires_in? integer
+---@field obtained_at? integer
+
+---@return table<string, any>
+local function gcal_config()
+  local cfg = config.get()
+  return cfg.gcal or {}
+end
+
+---@return string
+local function token_path()
+  return vim.fn.stdpath('data') .. '/pending/gcal_tokens.json'
+end
+
+---@return string
+local function credentials_path()
+  local gc = gcal_config()
+  return gc.credentials_path or (vim.fn.stdpath('data') .. '/pending/gcal_credentials.json')
+end
+
+---@param path string
+---@return table?
+local function load_json_file(path)
+  local f = io.open(path, 'r')
+  if not f then
+    return nil
+  end
+  local content = f:read('*a')
+  f:close()
+  if content == '' then
+    return nil
+  end
+  local ok, decoded = pcall(vim.json.decode, content)
+  if not ok then
+    return nil
+  end
+  return decoded
+end
+
+---@param path string
+---@param data table
+---@return boolean
+local function save_json_file(path, data)
+  local dir = vim.fn.fnamemodify(path, ':h')
+  if vim.fn.isdirectory(dir) == 0 then
+    vim.fn.mkdir(dir, 'p')
+  end
+  local f = io.open(path, 'w')
+  if not f then
+    return false
+  end
+  f:write(vim.json.encode(data))
+  f:close()
+  vim.fn.setfperm(path, 'rw-------')
+  return true
+end
+
+---@return pending.GcalCredentials?
+local function load_credentials()
+  local creds = load_json_file(credentials_path())
+  if not creds then
+    return nil
+  end
+  if creds.installed then
+    return creds.installed --[[@as pending.GcalCredentials]]
+  end
+  return creds --[[@as pending.GcalCredentials]]
+end
+
+---@return pending.GcalTokens?
+local function load_tokens()
+  return load_json_file(token_path()) --[[@as pending.GcalTokens?]]
+end
+
+---@param tokens pending.GcalTokens
+---@return boolean
+local function save_tokens(tokens)
+  return save_json_file(token_path(), tokens)
+end
+
+---@param str string
+---@return string
+local function url_encode(str)
+  return (
+    str:gsub('([^%w%-%.%_%~])', function(c)
+      return string.format('%%%02X', string.byte(c))
+    end)
   )
-  if err then
+end
-    return nil, err
+
+---@param method string
+---@param url string
+---@param headers? string[]
+---@param body? string
+---@return table? result
+---@return string? err
+local function curl_request(method, url, headers, body)
+  local args = { 'curl', '-s', '-X', method }
+  for _, h in ipairs(headers or {}) do
+    table.insert(args, '-H')
+    table.insert(args, h)
   end
-  local result = {}
+  if body then
-  for _, item in ipairs(data and data.items or {}) do
+    table.insert(args, '-d')
-    if item.summary then
+    table.insert(args, body)
-      result[item.summary] = item.id
-    end
   end
-  return result, nil
+  table.insert(args, url)
+  local result = vim.system(args, { text = true }):wait()
+  if result.code ~= 0 then
+    return nil, 'curl failed: ' .. (result.stderr or '')
+  end
+  if not result.stdout or result.stdout == '' then
+    return {}, nil
+  end
+  local ok, decoded = pcall(vim.json.decode, result.stdout)
+  if not ok then
+    return nil, 'failed to parse response: ' .. result.stdout
+  end
+  if decoded.error then
+    return nil, 'API error: ' .. (decoded.error.message or vim.json.encode(decoded.error))
+  end
+  return decoded, nil
+end
+
+---@param access_token string
+---@return string[]
+local function auth_headers(access_token)
+  return {
+    'Authorization: Bearer ' .. access_token,
+    'Content-Type: application/json',
+  }
+end
+
+---@param creds pending.GcalCredentials
+---@param tokens pending.GcalTokens
+---@return pending.GcalTokens?
+local function refresh_access_token(creds, tokens)
+  local body = 'client_id='
+    .. url_encode(creds.client_id)
+    .. '&client_secret='
+    .. url_encode(creds.client_secret)
+    .. '&grant_type=refresh_token'
+    .. '&refresh_token='
+    .. url_encode(tokens.refresh_token)
+  local result = vim
+    .system({
+      'curl',
+      '-s',
+      '-X',
+      'POST',
+      '-H',
+      'Content-Type: application/x-www-form-urlencoded',
+      '-d',
+      body,
+      TOKEN_URL,
+    }, { text = true })
+    :wait()
+  if result.code ~= 0 then
+    return nil
+  end
+  local ok, decoded = pcall(vim.json.decode, result.stdout or '')
+  if not ok or not decoded.access_token then
+    return nil
+  end
+  tokens.access_token = decoded.access_token --[[@as string]]
+  tokens.expires_in = decoded.expires_in --[[@as integer?]]
+  tokens.obtained_at = os.time()
+  save_tokens(tokens)
+  return tokens
+end
+
+---@return string?
+local function get_access_token()
+  local creds = load_credentials()
+  if not creds then
+    vim.notify(
+      'pending.nvim: No Google Calendar credentials found at ' .. credentials_path(),
+      vim.log.levels.ERROR
+    )
+    return nil
+  end
+  local tokens = load_tokens()
+  if not tokens or not tokens.refresh_token then
+    M.authorize()
+    tokens = load_tokens()
+    if not tokens then
+      return nil
+    end
+  end
+  local now = os.time()
+  local obtained = tokens.obtained_at or 0
+  local expires = tokens.expires_in or 3600
+  if now - obtained > expires - 60 then
+    tokens = refresh_access_token(creds, tokens)
+    if not tokens then
+      vim.notify('pending.nvim: Failed to refresh access token.', vim.log.levels.ERROR)
+      return nil
+    end
+  end
+  return tokens.access_token
+end
+
+function M.authorize()
+  local creds = load_credentials()
+  if not creds then
+    vim.notify(
+      'pending.nvim: No Google Calendar credentials found at ' .. credentials_path(),
+      vim.log.levels.ERROR
+    )
+    return
+  end
+
+  local port = 18392
+  local verifier_chars = 'ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789-._~'
+  local verifier = {}
+  math.randomseed(os.time())
+  for _ = 1, 64 do
+    local idx = math.random(1, #verifier_chars)
+    table.insert(verifier, verifier_chars:sub(idx, idx))
+  end
+  local code_verifier = table.concat(verifier)
+
+  local sha_pipe = vim
+    .system({
+      'sh',
+      '-c',
+      'printf "%s" "'
+        .. code_verifier
+        .. '" | openssl dgst -sha256 -binary | openssl base64 -A | tr "+/" "-_" | tr -d "="',
+    }, { text = true })
+    :wait()
+  local code_challenge = sha_pipe.stdout or ''
+
+  local auth_url = AUTH_URL
+    .. '?client_id='
+    .. url_encode(creds.client_id)
+    .. '&redirect_uri='
+    .. url_encode('http://127.0.0.1:' .. port)
+    .. '&response_type=code'
+    .. '&scope='
+    .. url_encode(SCOPE)
+    .. '&access_type=offline'
+    .. '&prompt=consent'
+    .. '&code_challenge='
+    .. url_encode(code_challenge)
+    .. '&code_challenge_method=S256'
+
+  vim.ui.open(auth_url)
+  vim.notify('pending.nvim: Opening browser for Google authorization...')
+
+  local server = vim.uv.new_tcp()
+  server:bind('127.0.0.1', port)
+  server:listen(1, function(err)
+    if err then
+      return
+    end
+    local client = vim.uv.new_tcp()
+    server:accept(client)
+    client:read_start(function(read_err, data)
+      if read_err or not data then
+        return
+      end
+      local code = data:match('[?&]code=([^&%s]+)')
+      local response_body = code
+          and '<html><body><h1>Authorization successful</h1><p>You can close this tab.</p></body></html>'
+        or '<html><body><h1>Authorization failed</h1></body></html>'
+      local http_response = 'HTTP/1.1 200 OK\r\nContent-Type: text/html\r\nConnection: close\r\n\r\n'
+        .. response_body
+      client:write(http_response, function()
+        client:shutdown(function()
+          client:close()
+        end)
+      end)
+      server:close()
+      if code then
+        vim.schedule(function()
+          M._exchange_code(creds, code, code_verifier, port)
+        end)
+      end
+    end)
+  end)
+end
+
+---@param creds pending.GcalCredentials
+---@param code string
+---@param code_verifier string
+---@param port integer
+function M._exchange_code(creds, code, code_verifier, port)
+  local body = 'client_id='
+    .. url_encode(creds.client_id)
+    .. '&client_secret='
+    .. url_encode(creds.client_secret)
+    .. '&code='
+    .. url_encode(code)
+    .. '&code_verifier='
+    .. url_encode(code_verifier)
+    .. '&grant_type=authorization_code'
+    .. '&redirect_uri='
+    .. url_encode('http://127.0.0.1:' .. port)
+
+  local result = vim
+    .system({
+      'curl',
+      '-s',
+      '-X',
+      'POST',
+      '-H',
+      'Content-Type: application/x-www-form-urlencoded',
+      '-d',
+      body,
+      TOKEN_URL,
+    }, { text = true })
+    :wait()
+
+  if result.code ~= 0 then
+    vim.notify('pending.nvim: Token exchange failed.', vim.log.levels.ERROR)
+    return
+  end
+
+  local ok, decoded = pcall(vim.json.decode, result.stdout or '')
+  if not ok or not decoded.access_token then
+    vim.notify('pending.nvim: Invalid token response.', vim.log.levels.ERROR)
+    return
+  end
+
+  decoded.obtained_at = os.time()
+  save_tokens(decoded)
+  vim.notify('pending.nvim: Google Calendar authorized successfully.')
 end
 
 ---@param access_token string
----@param name string
----@param existing table<string, string>
 ---@return string? calendar_id
 ---@return string? err
-local function find_or_create_calendar(access_token, name, existing)
+local function find_or_create_calendar(access_token)
-  if existing[name] then
+  local gc = gcal_config()
-    return existing[name], nil
+  local cal_name = gc.calendar or 'Pendings'
-  end
+
-  local body = vim.json.encode({ summary = name })
+  local data, err =
-  local created, err =
+    curl_request('GET', BASE_URL .. '/users/me/calendarList', auth_headers(access_token))
-    oauth.curl_request('POST', BASE_URL .. '/calendars', oauth.auth_headers(access_token), body)
   if err then
     return nil, err
   end
-  local id = created and created.id
+
-  if id then
+  for _, item in ipairs(data and data.items or {}) do
-    existing[name] = id
+    if item.summary == cal_name then
+      return item.id, nil
+    end
   end
-  return id, nil
+
+  local body = vim.json.encode({ summary = cal_name })
+  local created, create_err =
+    curl_request('POST', BASE_URL .. '/calendars', auth_headers(access_token), body)
+  if create_err then
+    return nil, create_err
+  end
+
+  return created and created.id, nil
 end
 
 ---@param date_str string
 ---@return string
 local function next_day(date_str)
-  local y, m, d = date_str:match('^(%d%d%d%d)-(%d%d)-(%d%d)')
+  local y, m, d = date_str:match('^(%d%d%d%d)-(%d%d)-(%d%d)$')
   local t = os.time({ year = tonumber(y) or 0, month = tonumber(m) or 0, day = tonumber(d) or 0 })
     + 86400
   return os.date('%Y-%m-%d', t) --[[@as string]]
@@ -75,10 +399,10 @@ local function create_event(access_token, calendar_id, task)
       private = { taskId = tostring(task.id) },
     },
   }
-  local data, err = oauth.curl_request(
+  local data, err = curl_request(
     'POST',
-    BASE_URL .. '/calendars/' .. oauth.url_encode(calendar_id) .. '/events',
+    BASE_URL .. '/calendars/' .. url_encode(calendar_id) .. '/events',
-    oauth.auth_headers(access_token),
+    auth_headers(access_token),
     vim.json.encode(event)
   )
   if err then
@@ -97,16 +421,11 @@ local function update_event(access_token, calendar_id, event_id, task)
     summary = task.description,
     start = { date = task.due },
     ['end'] = { date = next_day(task.due or '') },
-    transparency = 'transparent',
   }
-  local _, err = oauth.curl_request(
+  local _, err = curl_request(
     'PATCH',
-    BASE_URL
+    BASE_URL .. '/calendars/' .. url_encode(calendar_id) .. '/events/' .. url_encode(event_id),
-      .. '/calendars/'
+    auth_headers(access_token),
-      .. oauth.url_encode(calendar_id)
-      .. '/events/'
-      .. oauth.url_encode(event_id),
-    oauth.auth_headers(access_token),
     vim.json.encode(event)
   )
   return err
@@ -117,129 +436,81 @@ end
 ---@param event_id string
 ---@return string? err
 local function delete_event(access_token, calendar_id, event_id)
-  local _, err = oauth.curl_request(
+  local _, err = curl_request(
     'DELETE',
-    BASE_URL
+    BASE_URL .. '/calendars/' .. url_encode(calendar_id) .. '/events/' .. url_encode(event_id),
-      .. '/calendars/'
+    auth_headers(access_token)
-      .. oauth.url_encode(calendar_id)
-      .. '/events/'
-      .. oauth.url_encode(event_id),
-    oauth.auth_headers(access_token)
   )
   return err
 end
 
----@param callback fun(access_token: string): nil
+function M.sync()
-local function with_token(callback)
+  local access_token = get_access_token()
-  oauth.async(function()
+  if not access_token then
-    local token = oauth.google_client:get_access_token()
+    return
-    if not token then
+  end
-      oauth.google_client:auth(function()
-        oauth.async(function()
-          local fresh = oauth.google_client:get_access_token()
-          if fresh then
-            callback(fresh)
-          else
-            log.error(oauth.google_client.name .. ': authorization failed or was cancelled')
-          end
-        end)
-      end)
-      return
-    end
-    callback(token)
-  end)
-end
 
-function M.push()
+  local calendar_id, err = find_or_create_calendar(access_token)
-  with_token(function(access_token)
+  if err or not calendar_id then
-    local calendars, cal_err = get_all_calendars(access_token)
+    vim.notify('pending.nvim: ' .. (err or 'calendar not found'), vim.log.levels.ERROR)
-    if cal_err or not calendars then
+    return
-      log.error(cal_err or 'failed to fetch calendars')
+  end
-      return
-    end
 
-    local s = require('pending').store()
+  local tasks = store.tasks()
-    local created, updated, deleted = 0, 0, 0
+  local created, updated, deleted = 0, 0, 0
 
-    for _, task in ipairs(s:tasks()) do
+  for _, task in ipairs(tasks) do
-      local extra = task._extra or {}
+    local extra = task._extra or {}
-      local event_id = extra['_gcal_event_id'] --[[@as string?]]
+    local event_id = extra['_gcal_event_id'] --[[@as string?]]
-      local cal_id = extra['_gcal_calendar_id'] --[[@as string?]]
 
-      local should_delete = event_id ~= nil
+    local should_delete = event_id ~= nil
-        and cal_id ~= nil
+      and (
-        and (
+        task.status == 'done'
-          task.status == 'done'
+        or task.status == 'deleted'
-          or task.status == 'deleted'
+        or (task.status == 'pending' and not task.due)
-          or (task.status == 'pending' and not task.due)
+      )
-        )
 
-      if should_delete then
+    if should_delete and event_id then
-        local del_err =
+      local del_err = delete_event(access_token, calendar_id, event_id) --[[@as string]]
-          delete_event(access_token, cal_id --[[@as string]], event_id --[[@as string]])
+      if not del_err then
-        if del_err then
+        extra['_gcal_event_id'] = nil
-          log.warn('gcal delete failed: ' .. del_err)
+        if next(extra) == nil then
+          task._extra = nil
         else
-          extra['_gcal_event_id'] = nil
+          task._extra = extra
-          extra['_gcal_calendar_id'] = nil
-          if next(extra) == nil then
-            task._extra = nil
-          else
-            task._extra = extra
-          end
-          task.modified = os.date('!%Y-%m-%dT%H:%M:%SZ') --[[@as string]]
-          deleted = deleted + 1
         end
-      elseif task.status == 'pending' and task.due then
+        task.modified = os.date('!%Y-%m-%dT%H:%M:%SZ') --[[@as string]]
-        local cat = task.category or config.get().default_category
+        deleted = deleted + 1
-        if event_id and cal_id then
+      end
-          local upd_err = update_event(access_token, cal_id, event_id, task)
+    elseif task.status == 'pending' and task.due then
-          if upd_err then
+      if event_id then
-            log.warn('gcal update failed: ' .. upd_err)
+        local upd_err = update_event(access_token, calendar_id, event_id, task)
-          else
+        if not upd_err then
-            updated = updated + 1
+          updated = updated + 1
-          end
+        end
-        else
+      else
-          local lid, lid_err = find_or_create_calendar(access_token, cat, calendars)
+        local new_id, create_err = create_event(access_token, calendar_id, task)
-          if lid_err or not lid then
+        if not create_err and new_id then
-            log.warn('gcal calendar failed: ' .. (lid_err or 'unknown'))
+          if not task._extra then
-          else
+            task._extra = {}
-            local new_id, create_err = create_event(access_token, lid, task)
-            if create_err then
-              log.warn('gcal create failed: ' .. create_err)
-            elseif new_id then
-              if not task._extra then
-                task._extra = {}
-              end
-              task._extra['_gcal_event_id'] = new_id
-              task._extra['_gcal_calendar_id'] = lid
-              task.modified = os.date('!%Y-%m-%dT%H:%M:%SZ') --[[@as string]]
-              created = created + 1
-            end
           end
+          task._extra['_gcal_event_id'] = new_id
+          task.modified = os.date('!%Y-%m-%dT%H:%M:%SZ') --[[@as string]]
+          created = created + 1
         end
       end
     end
-
-    s:save()
-    require('pending')._recompute_counts()
-    local buffer = require('pending.buffer')
-    if buffer.bufnr() and vim.api.nvim_buf_is_valid(buffer.bufnr()) then
-      buffer.render(buffer.bufnr())
-    end
-    log.info(string.format('Google Calendar pushed — +%d ~%d -%d', created, updated, deleted))
-  end)
-end
-
----@return nil
-function M.health()
-  oauth.health(M.name)
-  local tokens = oauth.google_client:load_tokens()
-  if tokens and tokens.refresh_token then
-    vim.health.ok('gcal tokens found')
-  else
-    vim.health.info('no gcal tokens — run :Pending auth')
   end
+
+  store.save()
+  vim.notify(
+    string.format(
+      'pending.nvim: Synced to Google Calendar (created: %d, updated: %d, deleted: %d)',
+      created,
+      updated,
+      deleted
+    )
+  )
 end
 
 return M

lua/pending/sync/gtasks.lua

@@ -1,533 +0,0 @@
-local config = require('pending.config')
-local log = require('pending.log')
-local oauth = require('pending.sync.oauth')
-
-local M = {}
-
-M.name = 'gtasks'
-
-local BASE_URL = 'https://tasks.googleapis.com/tasks/v1'
-
----@param access_token string
----@return table<string, string>? name_to_id
----@return string? err
-local function get_all_tasklists(access_token)
-  local data, err =
-    oauth.curl_request('GET', BASE_URL .. '/users/@me/lists', oauth.auth_headers(access_token))
-  if err then
-    return nil, err
-  end
-  local result = {}
-  for _, item in ipairs(data and data.items or {}) do
-    result[item.title] = item.id
-  end
-  return result, nil
-end
-
----@param access_token string
----@param name string
----@param existing table<string, string>
----@return string? list_id
----@return string? err
-local function find_or_create_tasklist(access_token, name, existing)
-  if existing[name] then
-    return existing[name], nil
-  end
-  local body = vim.json.encode({ title = name })
-  local created, err = oauth.curl_request(
-    'POST',
-    BASE_URL .. '/users/@me/lists',
-    oauth.auth_headers(access_token),
-    body
-  )
-  if err then
-    return nil, err
-  end
-  local id = created and created.id
-  if id then
-    existing[name] = id
-  end
-  return id, nil
-end
-
----@param access_token string
----@param list_id string
----@return table[]? items
----@return string? err
-local function list_gtasks(access_token, list_id)
-  local url = BASE_URL
-    .. '/lists/'
-    .. oauth.url_encode(list_id)
-    .. '/tasks?showCompleted=true&showHidden=true'
-  local data, err = oauth.curl_request('GET', url, oauth.auth_headers(access_token))
-  if err then
-    return nil, err
-  end
-  return data and data.items or {}, nil
-end
-
----@param access_token string
----@param list_id string
----@param body table
----@return string? task_id
----@return string? err
-local function create_gtask(access_token, list_id, body)
-  local data, err = oauth.curl_request(
-    'POST',
-    BASE_URL .. '/lists/' .. oauth.url_encode(list_id) .. '/tasks',
-    oauth.auth_headers(access_token),
-    vim.json.encode(body)
-  )
-  if err then
-    return nil, err
-  end
-  return data and data.id, nil
-end
-
----@param access_token string
----@param list_id string
----@param task_id string
----@param body table
----@return string? err
-local function update_gtask(access_token, list_id, task_id, body)
-  local _, err = oauth.curl_request(
-    'PATCH',
-    BASE_URL .. '/lists/' .. oauth.url_encode(list_id) .. '/tasks/' .. oauth.url_encode(task_id),
-    oauth.auth_headers(access_token),
-    vim.json.encode(body)
-  )
-  return err
-end
-
----@param access_token string
----@param list_id string
----@param task_id string
----@return string? err
-local function delete_gtask(access_token, list_id, task_id)
-  local _, err = oauth.curl_request(
-    'DELETE',
-    BASE_URL .. '/lists/' .. oauth.url_encode(list_id) .. '/tasks/' .. oauth.url_encode(task_id),
-    oauth.auth_headers(access_token)
-  )
-  return err
-end
-
----@param due string YYYY-MM-DD or YYYY-MM-DDThh:mm
----@return string RFC 3339
-local function due_to_rfc3339(due)
-  local date = due:match('^(%d%d%d%d%-%d%d%-%d%d)')
-  return (date or due) .. 'T00:00:00.000Z'
-end
-
----@param rfc string RFC 3339 from GTasks
----@return string YYYY-MM-DD
-local function rfc3339_to_date(rfc)
-  return rfc:match('^(%d%d%d%d%-%d%d%-%d%d)') or rfc
-end
-
----@param task pending.Task
----@return string?
-local function build_notes(task)
-  local parts = {}
-  if task.priority and task.priority > 0 then
-    table.insert(parts, 'pri:' .. task.priority)
-  end
-  if task.recur then
-    local spec = task.recur
-    if task.recur_mode == 'completion' then
-      spec = '!' .. spec
-    end
-    table.insert(parts, 'rec:' .. spec)
-  end
-  if #parts == 0 then
-    return nil
-  end
-  return table.concat(parts, ' ')
-end
-
----@param notes string?
----@return integer priority
----@return string? recur
----@return string? recur_mode
-local function parse_notes(notes)
-  if not notes then
-    return 0, nil, nil
-  end
-  local priority = 0
-  local recur = nil
-  local recur_mode = nil
-  local pri = notes:match('pri:(%d+)')
-  if pri then
-    priority = tonumber(pri) or 0
-  end
-  local rec = notes:match('rec:(!?[%w]+)')
-  if rec then
-    if rec:sub(1, 1) == '!' then
-      recur = rec:sub(2)
-      recur_mode = 'completion'
-    else
-      recur = rec
-    end
-  end
-  return priority, recur, recur_mode
-end
-
----@param task pending.Task
----@return table
-local function task_to_gtask(task)
-  local body = {
-    title = task.description,
-    status = task.status == 'done' and 'completed' or 'needsAction',
-  }
-  if task.due then
-    body.due = due_to_rfc3339(task.due)
-  end
-  local notes = build_notes(task)
-  if notes then
-    body.notes = notes
-  end
-  return body
-end
-
----@param gtask table
----@param category string
----@return table fields for store:add / store:update
-local function gtask_to_fields(gtask, category)
-  local priority, recur, recur_mode = parse_notes(gtask.notes)
-  local fields = {
-    description = gtask.title or '',
-    category = category,
-    status = gtask.status == 'completed' and 'done' or 'pending',
-    priority = priority,
-    recur = recur,
-    recur_mode = recur_mode,
-  }
-  if gtask.due then
-    fields.due = rfc3339_to_date(gtask.due)
-  end
-  return fields
-end
-
----@param s pending.Store
----@return table<string, pending.Task>
-local function build_id_index(s)
-  ---@type table<string, pending.Task>
-  local index = {}
-  for _, task in ipairs(s:tasks()) do
-    local extra = task._extra or {}
-    local gtid = extra['_gtasks_task_id'] --[[@as string?]]
-    if gtid then
-      index[gtid] = task
-    end
-  end
-  return index
-end
-
----@param access_token string
----@param tasklists table<string, string>
----@param s pending.Store
----@param now_ts string
----@param by_gtasks_id table<string, pending.Task>
----@return integer created
----@return integer updated
----@return integer deleted
----@return integer failed
-local function push_pass(access_token, tasklists, s, now_ts, by_gtasks_id)
-  local created, updated, deleted, failed = 0, 0, 0, 0
-  for _, task in ipairs(s:tasks()) do
-    local extra = task._extra or {}
-    local gtid = extra['_gtasks_task_id'] --[[@as string?]]
-    local list_id = extra['_gtasks_list_id'] --[[@as string?]]
-
-    if task.status == 'deleted' and gtid and list_id then
-      local err = delete_gtask(access_token, list_id, gtid)
-      if err then
-        log.warn('gtasks delete failed: ' .. err)
-        failed = failed + 1
-      else
-        if not task._extra then
-          task._extra = {}
-        end
-        task._extra['_gtasks_task_id'] = nil
-        task._extra['_gtasks_list_id'] = nil
-        task._extra['_gtasks_synced_at'] = nil
-        if next(task._extra) == nil then
-          task._extra = nil
-        end
-        task.modified = now_ts
-        deleted = deleted + 1
-      end
-    elseif task.status ~= 'deleted' then
-      if gtid and list_id then
-        local synced_at = extra['_gtasks_synced_at'] --[[@as string?]]
-        if not synced_at or task.modified > synced_at then
-          local err = update_gtask(access_token, list_id, gtid, task_to_gtask(task))
-          if err then
-            log.warn('gtasks update failed: ' .. err)
-            failed = failed + 1
-          else
-            task._extra = task._extra or {}
-            task._extra['_gtasks_synced_at'] = now_ts
-            updated = updated + 1
-          end
-        end
-      elseif task.status == 'pending' then
-        local cat = task.category or config.get().default_category
-        local lid, err = find_or_create_tasklist(access_token, cat, tasklists)
-        if not err and lid then
-          local new_id, create_err = create_gtask(access_token, lid, task_to_gtask(task))
-          if create_err then
-            log.warn('gtasks create failed: ' .. create_err)
-            failed = failed + 1
-          elseif new_id then
-            if not task._extra then
-              task._extra = {}
-            end
-            task._extra['_gtasks_task_id'] = new_id
-            task._extra['_gtasks_list_id'] = lid
-            task._extra['_gtasks_synced_at'] = now_ts
-            task.modified = now_ts
-            by_gtasks_id[new_id] = task
-            created = created + 1
-          end
-        end
-      end
-    end
-  end
-  return created, updated, deleted, failed
-end
-
----@param access_token string
----@param tasklists table<string, string>
----@param s pending.Store
----@param now_ts string
----@param by_gtasks_id table<string, pending.Task>
----@return integer created
----@return integer updated
----@return integer failed
----@return table<string, true> seen_remote_ids
----@return table<string, true> fetched_list_ids
-local function pull_pass(access_token, tasklists, s, now_ts, by_gtasks_id)
-  local created, updated, failed = 0, 0, 0
-  ---@type table<string, true>
-  local seen_remote_ids = {}
-  ---@type table<string, true>
-  local fetched_list_ids = {}
-  for list_name, list_id in pairs(tasklists) do
-    local items, err = list_gtasks(access_token, list_id)
-    if err then
-      log.warn('error fetching list ' .. list_name .. ': ' .. err)
-      failed = failed + 1
-    else
-      fetched_list_ids[list_id] = true
-      for _, gtask in ipairs(items or {}) do
-        seen_remote_ids[gtask.id] = true
-        local local_task = by_gtasks_id[gtask.id]
-        if local_task then
-          local gtask_updated = gtask.updated or ''
-          local local_modified = local_task.modified or ''
-          if gtask_updated > local_modified then
-            local fields = gtask_to_fields(gtask, list_name)
-            for k, v in pairs(fields) do
-              local_task[k] = v
-            end
-            local_task._extra = local_task._extra or {}
-            local_task._extra['_gtasks_synced_at'] = now_ts
-            local_task.modified = now_ts
-            updated = updated + 1
-          end
-        else
-          local fields = gtask_to_fields(gtask, list_name)
-          fields._extra = {
-            _gtasks_task_id = gtask.id,
-            _gtasks_list_id = list_id,
-            _gtasks_synced_at = now_ts,
-          }
-          local new_task = s:add(fields)
-          by_gtasks_id[gtask.id] = new_task
-          created = created + 1
-        end
-      end
-    end
-  end
-  return created, updated, failed, seen_remote_ids, fetched_list_ids
-end
-
----@param s pending.Store
----@param seen_remote_ids table<string, true>
----@param fetched_list_ids table<string, true>
----@param now_ts string
----@return integer unlinked
-local function detect_remote_deletions(s, seen_remote_ids, fetched_list_ids, now_ts)
-  local unlinked = 0
-  for _, task in ipairs(s:tasks()) do
-    local extra = task._extra or {}
-    local gtid = extra['_gtasks_task_id']
-    local list_id = extra['_gtasks_list_id']
-    if
-      task.status ~= 'deleted'
-      and gtid
-      and list_id
-      and fetched_list_ids[list_id]
-      and not seen_remote_ids[gtid]
-    then
-      task._extra['_gtasks_task_id'] = nil
-      task._extra['_gtasks_list_id'] = nil
-      task._extra['_gtasks_synced_at'] = nil
-      if next(task._extra) == nil then
-        task._extra = nil
-      end
-      task.modified = now_ts
-      unlinked = unlinked + 1
-    end
-  end
-  return unlinked
-end
-
----@param access_token string
----@return table<string, string>? tasklists
----@return pending.Store? s
----@return string? now_ts
-local function sync_setup(access_token)
-  local tasklists, tl_err = get_all_tasklists(access_token)
-  if tl_err or not tasklists then
-    log.error(tl_err or 'failed to fetch task lists')
-    return nil, nil, nil
-  end
-  local s = require('pending').store()
-  local now_ts = os.date('!%Y-%m-%dT%H:%M:%SZ') --[[@as string]]
-  return tasklists, s, now_ts
-end
-
----@param callback fun(access_token: string): nil
-local function with_token(callback)
-  oauth.async(function()
-    local token = oauth.google_client:get_access_token()
-    if not token then
-      oauth.google_client:auth(function()
-        oauth.async(function()
-          local fresh = oauth.google_client:get_access_token()
-          if fresh then
-            callback(fresh)
-          else
-            log.error(oauth.google_client.name .. ': authorization failed or was cancelled')
-          end
-        end)
-      end)
-      return
-    end
-    callback(token)
-  end)
-end
-
-function M.push()
-  with_token(function(access_token)
-    local tasklists, s, now_ts = sync_setup(access_token)
-    if not tasklists then
-      return
-    end
-    ---@cast s pending.Store
-    ---@cast now_ts string
-    local by_gtasks_id = build_id_index(s)
-    local created, updated, deleted, failed =
-      push_pass(access_token, tasklists, s, now_ts, by_gtasks_id)
-    s:save()
-    require('pending')._recompute_counts()
-    local buffer = require('pending.buffer')
-    if buffer.bufnr() and vim.api.nvim_buf_is_valid(buffer.bufnr()) then
-      buffer.render(buffer.bufnr())
-    end
-    log.info(
-      string.format('Google Tasks pushed — +%d ~%d -%d !%d', created, updated, deleted, failed)
-    )
-  end)
-end
-
-function M.pull()
-  with_token(function(access_token)
-    local tasklists, s, now_ts = sync_setup(access_token)
-    if not tasklists then
-      return
-    end
-    ---@cast s pending.Store
-    ---@cast now_ts string
-    local by_gtasks_id = build_id_index(s)
-    local created, updated, failed, seen_remote_ids, fetched_list_ids =
-      pull_pass(access_token, tasklists, s, now_ts, by_gtasks_id)
-    local unlinked = detect_remote_deletions(s, seen_remote_ids, fetched_list_ids, now_ts)
-    s:save()
-    require('pending')._recompute_counts()
-    local buffer = require('pending.buffer')
-    if buffer.bufnr() and vim.api.nvim_buf_is_valid(buffer.bufnr()) then
-      buffer.render(buffer.bufnr())
-    end
-    log.info(
-      string.format(
-        'Google Tasks pulled — +%d ~%d !%d, unlinked: %d',
-        created,
-        updated,
-        failed,
-        unlinked
-      )
-    )
-  end)
-end
-
-function M.sync()
-  with_token(function(access_token)
-    local tasklists, s, now_ts = sync_setup(access_token)
-    if not tasklists then
-      return
-    end
-    ---@cast s pending.Store
-    ---@cast now_ts string
-    local by_gtasks_id = build_id_index(s)
-    local pushed_create, pushed_update, pushed_delete, pushed_failed =
-      push_pass(access_token, tasklists, s, now_ts, by_gtasks_id)
-    local pulled_create, pulled_update, pulled_failed, seen_remote_ids, fetched_list_ids =
-      pull_pass(access_token, tasklists, s, now_ts, by_gtasks_id)
-    local unlinked = detect_remote_deletions(s, seen_remote_ids, fetched_list_ids, now_ts)
-    s:save()
-    require('pending')._recompute_counts()
-    local buffer = require('pending.buffer')
-    if buffer.bufnr() and vim.api.nvim_buf_is_valid(buffer.bufnr()) then
-      buffer.render(buffer.bufnr())
-    end
-    log.info(
-      string.format(
-        'Google Tasks synced — push: +%d ~%d -%d !%d, pull: +%d ~%d !%d, unlinked: %d',
-        pushed_create,
-        pushed_update,
-        pushed_delete,
-        pushed_failed,
-        pulled_create,
-        pulled_update,
-        pulled_failed,
-        unlinked
-      )
-    )
-  end)
-end
-
-M._due_to_rfc3339 = due_to_rfc3339
-M._rfc3339_to_date = rfc3339_to_date
-M._build_notes = build_notes
-M._parse_notes = parse_notes
-M._task_to_gtask = task_to_gtask
-M._gtask_to_fields = gtask_to_fields
-M._push_pass = push_pass
-M._pull_pass = pull_pass
-M._detect_remote_deletions = detect_remote_deletions
-
----@return nil
-function M.health()
-  oauth.health(M.name)
-  local tokens = oauth.google_client:load_tokens()
-  if tokens and tokens.refresh_token then
-    vim.health.ok('gtasks tokens found')
-  else
-    vim.health.info('no gtasks tokens — run :Pending auth')
-  end
-end
-
-return M

lua/pending/sync/oauth.lua

@@ -1,521 +0,0 @@
-local config = require('pending.config')
-local log = require('pending.log')
-
-local TOKEN_URL = 'https://oauth2.googleapis.com/token'
-local AUTH_URL = 'https://accounts.google.com/o/oauth2/v2/auth'
-
-local BUNDLED_CLIENT_ID = 'PLACEHOLDER'
-local BUNDLED_CLIENT_SECRET = 'PLACEHOLDER'
-
----@class pending.OAuthCredentials
----@field client_id string
----@field client_secret string
-
----@class pending.OAuthTokens
----@field access_token string
----@field refresh_token string
----@field expires_in? integer
----@field obtained_at? integer
-
----@class pending.OAuthClient
----@field name string
----@field scope string
----@field port integer
----@field config_key string
-local OAuthClient = {}
-OAuthClient.__index = OAuthClient
-
----@class pending.oauth
-local M = {}
-
----@param args string[]
----@param opts? table
----@return { code: integer, stdout: string, stderr: string }
-function M.system(args, opts)
-  local co = coroutine.running()
-  if not co then
-    return vim.system(args, opts or {}):wait() --[[@as { code: integer, stdout: string, stderr: string }]]
-  end
-  vim.system(args, opts or {}, function(result)
-    vim.schedule(function()
-      coroutine.resume(co, result)
-    end)
-  end)
-  return coroutine.yield() --[[@as { code: integer, stdout: string, stderr: string }]]
-end
-
----@param fn fun(): nil
-function M.async(fn)
-  coroutine.resume(coroutine.create(fn))
-end
-
----@param str string
----@return string
-function M.url_encode(str)
-  return (
-    str:gsub('([^%w%-%.%_%~])', function(c)
-      return string.format('%%%02X', string.byte(c))
-    end)
-  )
-end
-
----@param path string
----@return table?
-function M.load_json_file(path)
-  local f = io.open(path, 'r')
-  if not f then
-    return nil
-  end
-  local content = f:read('*a')
-  f:close()
-  if content == '' then
-    return nil
-  end
-  local ok, decoded = pcall(vim.json.decode, content)
-  if not ok then
-    return nil
-  end
-  return decoded
-end
-
----@param path string
----@param data table
----@return boolean
-function M.save_json_file(path, data)
-  local dir = vim.fn.fnamemodify(path, ':h')
-  if vim.fn.isdirectory(dir) == 0 then
-    vim.fn.mkdir(dir, 'p')
-  end
-  local f = io.open(path, 'w')
-  if not f then
-    return false
-  end
-  f:write(vim.json.encode(data))
-  f:close()
-  vim.fn.setfperm(path, 'rw-------')
-  return true
-end
-
----@param method string
----@param url string
----@param headers? string[]
----@param body? string
----@return table? result
----@return string? err
-function M.curl_request(method, url, headers, body)
-  local args = { 'curl', '-s', '-X', method }
-  for _, h in ipairs(headers or {}) do
-    table.insert(args, '-H')
-    table.insert(args, h)
-  end
-  if body then
-    table.insert(args, '-d')
-    table.insert(args, body)
-  end
-  table.insert(args, url)
-  local result = M.system(args, { text = true })
-  if result.code ~= 0 then
-    return nil, 'curl failed: ' .. (result.stderr or '')
-  end
-  if not result.stdout or result.stdout == '' then
-    return {}, nil
-  end
-  local ok, decoded = pcall(vim.json.decode, result.stdout)
-  if not ok then
-    return nil, 'failed to parse response: ' .. result.stdout
-  end
-  if decoded.error then
-    return nil, 'API error: ' .. (decoded.error.message or vim.json.encode(decoded.error))
-  end
-  return decoded, nil
-end
-
----@param access_token string
----@return string[]
-function M.auth_headers(access_token)
-  return {
-    'Authorization: Bearer ' .. access_token,
-    'Content-Type: application/json',
-  }
-end
-
----@param backend_name string
----@return nil
-function M.health(backend_name)
-  if vim.fn.executable('curl') == 1 then
-    vim.health.ok('curl found (required for ' .. backend_name .. ' sync)')
-  else
-    vim.health.warn('curl not found (needed for ' .. backend_name .. ' sync)')
-  end
-end
-
----@return string
-function OAuthClient:token_path()
-  return vim.fn.stdpath('data') .. '/pending/' .. self.name .. '_tokens.json'
-end
-
----@return pending.OAuthCredentials
-function OAuthClient:resolve_credentials()
-  local cfg = config.get()
-  local backend_cfg = (cfg.sync and cfg.sync[self.config_key]) or {}
-
-  if backend_cfg.client_id and backend_cfg.client_secret then
-    return {
-      client_id = backend_cfg.client_id,
-      client_secret = backend_cfg.client_secret,
-    }
-  end
-
-  local data_dir = vim.fn.stdpath('data') .. '/pending/'
-  local cred_paths = {}
-  if backend_cfg.credentials_path then
-    table.insert(cred_paths, backend_cfg.credentials_path)
-  end
-  table.insert(cred_paths, data_dir .. self.name .. '_credentials.json')
-  table.insert(cred_paths, data_dir .. 'google_credentials.json')
-  for _, cred_path in ipairs(cred_paths) do
-    if cred_path then
-      local creds = M.load_json_file(cred_path)
-      if creds then
-        if creds.installed then
-          creds = creds.installed
-        end
-        if creds.client_id and creds.client_secret then
-          return creds --[[@as pending.OAuthCredentials]]
-        end
-      end
-    end
-  end
-  return {
-    client_id = BUNDLED_CLIENT_ID,
-    client_secret = BUNDLED_CLIENT_SECRET,
-  }
-end
-
----@return pending.OAuthTokens?
-function OAuthClient:load_tokens()
-  return M.load_json_file(self:token_path()) --[[@as pending.OAuthTokens?]]
-end
-
----@param tokens pending.OAuthTokens
----@return boolean
-function OAuthClient:save_tokens(tokens)
-  return M.save_json_file(self:token_path(), tokens)
-end
-
----@param creds pending.OAuthCredentials
----@param tokens pending.OAuthTokens
----@return pending.OAuthTokens?
-function OAuthClient:refresh_access_token(creds, tokens)
-  local body = 'client_id='
-    .. M.url_encode(creds.client_id)
-    .. '&client_secret='
-    .. M.url_encode(creds.client_secret)
-    .. '&grant_type=refresh_token'
-    .. '&refresh_token='
-    .. M.url_encode(tokens.refresh_token)
-  local result = M.system({
-    'curl',
-    '-s',
-    '-X',
-    'POST',
-    '-H',
-    'Content-Type: application/x-www-form-urlencoded',
-    '-d',
-    body,
-    TOKEN_URL,
-  }, { text = true })
-  if result.code ~= 0 then
-    return nil
-  end
-  local ok, decoded = pcall(vim.json.decode, result.stdout or '')
-  if not ok or not decoded.access_token then
-    return nil
-  end
-  tokens.access_token = decoded.access_token --[[@as string]]
-  tokens.expires_in = decoded.expires_in --[[@as integer?]]
-  tokens.obtained_at = os.time()
-  self:save_tokens(tokens)
-  return tokens
-end
-
----@return string?
-function OAuthClient:get_access_token()
-  local creds = self:resolve_credentials()
-  local tokens = self:load_tokens()
-  if not tokens or not tokens.refresh_token then
-    return nil
-  end
-  local now = os.time()
-  local obtained = tokens.obtained_at or 0
-  local expires = tokens.expires_in or 3600
-  if now - obtained > expires - 60 then
-    tokens = self:refresh_access_token(creds, tokens)
-    if not tokens then
-      log.error(self.name .. ': token refresh failed — re-authenticating...')
-      return nil
-    end
-  end
-  return tokens.access_token
-end
-
----@return nil
-function OAuthClient:setup()
-  local choice = vim.fn.inputlist({
-    self.name .. ' setup:',
-    '1. Enter client ID and secret',
-    '2. Load from JSON file path',
-  })
-  vim.cmd.redraw()
-
-  local id, secret
-
-  if choice == 1 then
-    while true do
-      id = vim.trim(vim.fn.input(self.name .. ' client ID: '))
-      if id == '' then
-        return
-      end
-      if id:match('^%d+%-[%w_]+%.apps%.googleusercontent%.com$') then
-        break
-      end
-      vim.cmd.redraw()
-      vim.api.nvim_echo({
-        {
-          'invalid client ID — expected <numbers>-<hash>.apps.googleusercontent.com',
-          'ErrorMsg',
-        },
-      }, false, {})
-    end
-
-    while true do
-      secret = vim.trim(vim.fn.inputsecret(self.name .. ' client secret: '))
-      if secret == '' then
-        return
-      end
-      if secret:match('^GOCSPX%-') then
-        break
-      end
-      vim.cmd.redraw()
-      vim.api.nvim_echo(
-        { { 'invalid client secret — expected GOCSPX-...', 'ErrorMsg' } },
-        false,
-        {}
-      )
-    end
-  elseif choice == 2 then
-    local fpath
-    while true do
-      fpath = vim.trim(vim.fn.input(self.name .. ' credentials file: ', '', 'file'))
-      if fpath == '' then
-        return
-      end
-      fpath = vim.fn.expand(fpath)
-      local creds = M.load_json_file(fpath)
-      if creds then
-        if creds.installed then
-          creds = creds.installed
-        end
-        if creds.client_id and creds.client_secret then
-          id = creds.client_id
-          secret = creds.client_secret
-          break
-        end
-      end
-      vim.cmd.redraw()
-      vim.api.nvim_echo(
-        { { 'could not read client_id/client_secret from ' .. fpath, 'ErrorMsg' } },
-        false,
-        {}
-      )
-    end
-  else
-    return
-  end
-
-  vim.schedule(function()
-    local path = vim.fn.stdpath('data') .. '/pending/google_credentials.json'
-    local ok = M.save_json_file(path, { client_id = id, client_secret = secret })
-    if not ok then
-      log.error(self.name .. ': failed to save credentials')
-      return
-    end
-    log.info(self.name .. ': credentials saved, starting authorization...')
-    self:auth()
-  end)
-end
-
----@param on_complete? fun(): nil
----@return nil
-function OAuthClient:auth(on_complete)
-  local creds = self:resolve_credentials()
-  if creds.client_id == BUNDLED_CLIENT_ID then
-    log.error(self.name .. ': no credentials configured — run :Pending auth')
-    return
-  end
-  local port = self.port
-
-  local verifier_chars = 'ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789-._~'
-  local verifier = {}
-  math.randomseed(vim.uv.hrtime())
-  for _ = 1, 64 do
-    local idx = math.random(1, #verifier_chars)
-    table.insert(verifier, verifier_chars:sub(idx, idx))
-  end
-  local code_verifier = table.concat(verifier)
-
-  local hex = vim.fn.sha256(code_verifier)
-  local binary = hex:gsub('..', function(h)
-    return string.char(tonumber(h, 16))
-  end)
-  local code_challenge = vim.base64.encode(binary):gsub('+', '-'):gsub('/', '_'):gsub('=', '')
-
-  local auth_url = AUTH_URL
-    .. '?client_id='
-    .. M.url_encode(creds.client_id)
-    .. '&redirect_uri='
-    .. M.url_encode('http://127.0.0.1:' .. port)
-    .. '&response_type=code'
-    .. '&scope='
-    .. M.url_encode(self.scope)
-    .. '&access_type=offline'
-    .. '&prompt=consent'
-    .. '&code_challenge='
-    .. M.url_encode(code_challenge)
-    .. '&code_challenge_method=S256'
-
-  vim.ui.open(auth_url)
-  log.info('Opening browser for Google authorization...')
-
-  local server = vim.uv.new_tcp()
-  local server_closed = false
-  local function close_server()
-    if server_closed then
-      return
-    end
-    server_closed = true
-    server:close()
-  end
-
-  server:bind('127.0.0.1', port)
-  server:listen(1, function(err)
-    if err then
-      return
-    end
-    local conn = vim.uv.new_tcp()
-    server:accept(conn)
-    conn:read_start(function(read_err, data)
-      if read_err or not data then
-        conn:close()
-        close_server()
-        return
-      end
-      local code = data:match('[?&]code=([^&%s]+)')
-      local response_body = code
-          and '<html><body><h1>Authorization successful</h1><p>You can close this tab.</p></body></html>'
-        or '<html><body><h1>Authorization failed</h1></body></html>'
-      local http_response = 'HTTP/1.1 200 OK\r\nContent-Type: text/html\r\nConnection: close\r\n\r\n'
-        .. response_body
-      conn:write(http_response, function()
-        conn:shutdown(function()
-          conn:close()
-        end)
-      end)
-      close_server()
-      if code then
-        vim.schedule(function()
-          self:_exchange_code(creds, code, code_verifier, port, on_complete)
-        end)
-      end
-    end)
-  end)
-
-  vim.defer_fn(function()
-    if not server_closed then
-      close_server()
-      log.warn('OAuth callback timed out (120s).')
-    end
-  end, 120000)
-end
-
----@param creds pending.OAuthCredentials
----@param code string
----@param code_verifier string
----@param port integer
----@param on_complete? fun(): nil
----@return nil
-function OAuthClient:_exchange_code(creds, code, code_verifier, port, on_complete)
-  local body = 'client_id='
-    .. M.url_encode(creds.client_id)
-    .. '&client_secret='
-    .. M.url_encode(creds.client_secret)
-    .. '&code='
-    .. M.url_encode(code)
-    .. '&code_verifier='
-    .. M.url_encode(code_verifier)
-    .. '&grant_type=authorization_code'
-    .. '&redirect_uri='
-    .. M.url_encode('http://127.0.0.1:' .. port)
-
-  local result = M.system({
-    'curl',
-    '-s',
-    '-X',
-    'POST',
-    '-H',
-    'Content-Type: application/x-www-form-urlencoded',
-    '-d',
-    body,
-    TOKEN_URL,
-  }, { text = true })
-
-  if result.code ~= 0 then
-    self:_wipe()
-    log.error('Token exchange failed.')
-    return
-  end
-
-  local ok, decoded = pcall(vim.json.decode, result.stdout or '')
-  if not ok or not decoded.access_token then
-    self:_wipe()
-    log.error('Invalid token response.')
-    return
-  end
-
-  decoded.obtained_at = os.time()
-  self:save_tokens(decoded)
-  log.info(self.name .. ' authorized successfully.')
-  if on_complete then
-    on_complete()
-  end
-end
-
----@return nil
-function OAuthClient:_wipe()
-  os.remove(self:token_path())
-  os.remove(vim.fn.stdpath('data') .. '/pending/google_credentials.json')
-end
-
----@param opts { name: string, scope: string, port: integer, config_key: string }
----@return pending.OAuthClient
-function M.new(opts)
-  return setmetatable({
-    name = opts.name,
-    scope = opts.scope,
-    port = opts.port,
-    config_key = opts.config_key,
-  }, OAuthClient)
-end
-
-M._BUNDLED_CLIENT_ID = BUNDLED_CLIENT_ID
-M._BUNDLED_CLIENT_SECRET = BUNDLED_CLIENT_SECRET
-M.BUNDLED_CLIENT_ID = BUNDLED_CLIENT_ID
-
-M.google_client = M.new({
-  name = 'google',
-  scope = 'https://www.googleapis.com/auth/tasks' .. ' https://www.googleapis.com/auth/calendar',
-  port = 18392,
-  config_key = 'google',
-})
-
-return M

lua/pending/textobj.lua

@@ -1,383 +0,0 @@
-local buffer = require('pending.buffer')
-local config = require('pending.config')
-local log = require('pending.log')
-
----@class pending.textobj
-local M = {}
-
----@param ... any
----@return nil
-local function dbg(...)
-  log.debug(string.format(...))
-end
-
----@param lnum integer
----@param meta pending.LineMeta[]
----@return string
-local function get_line_from_buf(lnum, meta)
-  local _ = meta
-  local bufnr = buffer.bufnr()
-  if not bufnr then
-    return ''
-  end
-  local lines = vim.api.nvim_buf_get_lines(bufnr, lnum - 1, lnum, false)
-  return lines[1] or ''
-end
-
----@param line string
----@return integer start_col
----@return integer end_col
-function M.inner_task_range(line)
-  local prefix_end = line:find('/') and select(2, line:find('^/%d+/%- %[.%] '))
-  if not prefix_end then
-    prefix_end = select(2, line:find('^%- %[.%] ')) or 0
-  end
-  local start_col = prefix_end + 1
-
-  local dk = config.get().date_syntax or 'due'
-  local rk = config.get().recur_syntax or 'rec'
-  local dk_pat = '^' .. vim.pesc(dk) .. ':%S+$'
-  local rk_pat = '^' .. vim.pesc(rk) .. ':%S+$'
-
-  local rest = line:sub(start_col)
-  local words = {}
-  for word in rest:gmatch('%S+') do
-    table.insert(words, word)
-  end
-
-  local i = #words
-  while i >= 1 do
-    local word = words[i]
-    if word:match(dk_pat) or word:match('^cat:%S+$') or word:match(rk_pat) then
-      i = i - 1
-    else
-      break
-    end
-  end
-
-  if i < 1 then
-    return start_col, start_col
-  end
-
-  local desc = table.concat(words, ' ', 1, i)
-  local end_col = start_col + #desc - 1
-  return start_col, end_col
-end
-
----@param row integer
----@param meta pending.LineMeta[]
----@return integer? header_row
----@return integer? last_row
-function M.category_bounds(row, meta)
-  if not meta or #meta == 0 then
-    return nil, nil
-  end
-
-  local header_row = nil
-  local m = meta[row]
-  if not m then
-    return nil, nil
-  end
-
-  if m.type == 'header' then
-    header_row = row
-  else
-    for r = row, 1, -1 do
-      if meta[r] and meta[r].type == 'header' then
-        header_row = r
-        break
-      end
-    end
-  end
-
-  if not header_row then
-    return nil, nil
-  end
-
-  local last_row = header_row
-  local total = #meta
-  for r = header_row + 1, total do
-    if meta[r].type == 'header' then
-      break
-    end
-    last_row = r
-  end
-
-  return header_row, last_row
-end
-
----@param count integer
----@return nil
-function M.a_task(count)
-  local meta = buffer.meta()
-  if not meta or #meta == 0 then
-    return
-  end
-  local row = vim.api.nvim_win_get_cursor(0)[1]
-  local m = meta[row]
-  if not m or m.type ~= 'task' then
-    return
-  end
-
-  local start_row = row
-  local end_row = row
-  count = math.max(1, count)
-  for _ = 2, count do
-    local next_row = end_row + 1
-    if next_row > #meta then
-      break
-    end
-    if meta[next_row] and meta[next_row].type == 'task' then
-      end_row = next_row
-    else
-      break
-    end
-  end
-
-  vim.cmd('normal! ' .. start_row .. 'GV' .. end_row .. 'G')
-end
-
----@param count integer
----@return nil
-function M.a_task_visual(count)
-  vim.cmd('normal! \27')
-  M.a_task(count)
-end
-
----@param count integer
----@return nil
-function M.i_task(count)
-  local _ = count
-  local meta = buffer.meta()
-  if not meta or #meta == 0 then
-    return
-  end
-  local row = vim.api.nvim_win_get_cursor(0)[1]
-  local m = meta[row]
-  if not m or m.type ~= 'task' then
-    return
-  end
-
-  local line = get_line_from_buf(row, meta)
-  local start_col, end_col = M.inner_task_range(line)
-  if start_col > end_col then
-    return
-  end
-
-  vim.api.nvim_win_set_cursor(0, { row, start_col - 1 })
-  vim.cmd('normal! v')
-  vim.api.nvim_win_set_cursor(0, { row, end_col - 1 })
-end
-
----@param count integer
----@return nil
-function M.i_task_visual(count)
-  vim.cmd('normal! \27')
-  M.i_task(count)
-end
-
----@param count integer
----@return nil
-function M.a_category(count)
-  local _ = count
-  local meta = buffer.meta()
-  if not meta or #meta == 0 then
-    return
-  end
-  local view = buffer.current_view_name()
-  if view == 'priority' then
-    return
-  end
-
-  local row = vim.api.nvim_win_get_cursor(0)[1]
-  local header_row, last_row = M.category_bounds(row, meta)
-  if not header_row or not last_row then
-    return
-  end
-
-  local start_row = header_row
-  if header_row > 1 and meta[header_row - 1] and meta[header_row - 1].type == 'blank' then
-    start_row = header_row - 1
-  end
-  local end_row = last_row
-  if last_row < #meta and meta[last_row + 1] and meta[last_row + 1].type == 'blank' then
-    end_row = last_row + 1
-  end
-
-  vim.cmd('normal! ' .. start_row .. 'GV' .. end_row .. 'G')
-end
-
----@param count integer
----@return nil
-function M.a_category_visual(count)
-  vim.cmd('normal! \27')
-  M.a_category(count)
-end
-
----@param count integer
----@return nil
-function M.i_category(count)
-  local _ = count
-  local meta = buffer.meta()
-  if not meta or #meta == 0 then
-    return
-  end
-  local view = buffer.current_view_name()
-  if view == 'priority' then
-    return
-  end
-
-  local row = vim.api.nvim_win_get_cursor(0)[1]
-  local header_row, last_row = M.category_bounds(row, meta)
-  if not header_row or not last_row then
-    return
-  end
-
-  local first_task = nil
-  local last_task = nil
-  for r = header_row + 1, last_row do
-    if meta[r] and meta[r].type == 'task' then
-      if not first_task then
-        first_task = r
-      end
-      last_task = r
-    end
-  end
-
-  if not first_task or not last_task then
-    return
-  end
-
-  vim.cmd('normal! ' .. first_task .. 'GV' .. last_task .. 'G')
-end
-
----@param count integer
----@return nil
-function M.i_category_visual(count)
-  vim.cmd('normal! \27')
-  M.i_category(count)
-end
-
----@param count integer
----@return nil
-function M.next_header(count)
-  local meta = buffer.meta()
-  if not meta or #meta == 0 then
-    return
-  end
-  local view = buffer.current_view_name()
-  if view == 'priority' then
-    return
-  end
-
-  local row = vim.api.nvim_win_get_cursor(0)[1]
-  dbg('next_header: cursor=%d, meta_len=%d, view=%s', row, #meta, view or 'nil')
-  local found = 0
-  count = math.max(1, count)
-  for r = row + 1, #meta do
-    if meta[r] and meta[r].type == 'header' then
-      found = found + 1
-      dbg(
-        'next_header: found header at row=%d, cat=%s, found=%d/%d',
-        r,
-        meta[r].category or '?',
-        found,
-        count
-      )
-      if found == count then
-        vim.api.nvim_win_set_cursor(0, { r, 0 })
-        dbg('next_header: cursor set to row=%d, actual=%d', r, vim.api.nvim_win_get_cursor(0)[1])
-        return
-      end
-    else
-      dbg('next_header: row=%d type=%s', r, meta[r] and meta[r].type or 'nil')
-    end
-  end
-  dbg('next_header: no header found after row=%d', row)
-end
-
----@param count integer
----@return nil
-function M.prev_header(count)
-  local meta = buffer.meta()
-  if not meta or #meta == 0 then
-    return
-  end
-  local view = buffer.current_view_name()
-  if view == 'priority' then
-    return
-  end
-
-  local row = vim.api.nvim_win_get_cursor(0)[1]
-  dbg('prev_header: cursor=%d, meta_len=%d', row, #meta)
-  local found = 0
-  count = math.max(1, count)
-  for r = row - 1, 1, -1 do
-    if meta[r] and meta[r].type == 'header' then
-      found = found + 1
-      dbg(
-        'prev_header: found header at row=%d, cat=%s, found=%d/%d',
-        r,
-        meta[r].category or '?',
-        found,
-        count
-      )
-      if found == count then
-        vim.api.nvim_win_set_cursor(0, { r, 0 })
-        return
-      end
-    end
-  end
-end
-
----@param count integer
----@return nil
-function M.next_task(count)
-  local meta = buffer.meta()
-  if not meta or #meta == 0 then
-    return
-  end
-
-  local row = vim.api.nvim_win_get_cursor(0)[1]
-  dbg('next_task: cursor=%d, meta_len=%d', row, #meta)
-  local found = 0
-  count = math.max(1, count)
-  for r = row + 1, #meta do
-    if meta[r] and meta[r].type == 'task' then
-      found = found + 1
-      if found == count then
-        dbg('next_task: jumping to row=%d', r)
-        vim.api.nvim_win_set_cursor(0, { r, 0 })
-        return
-      end
-    end
-  end
-  dbg('next_task: no task found after row=%d', row)
-end
-
----@param count integer
----@return nil
-function M.prev_task(count)
-  local meta = buffer.meta()
-  if not meta or #meta == 0 then
-    return
-  end
-
-  local row = vim.api.nvim_win_get_cursor(0)[1]
-  dbg('prev_task: cursor=%d, meta_len=%d', row, #meta)
-  local found = 0
-  count = math.max(1, count)
-  for r = row - 1, 1, -1 do
-    if meta[r] and meta[r].type == 'task' then
-      found = found + 1
-      if found == count then
-        dbg('prev_task: jumping to row=%d', r)
-        vim.api.nvim_win_set_cursor(0, { r, 0 })
-        return
-      end
-    end
-  end
-  dbg('prev_task: no task found before row=%d', row)
-end
-
-return M

lua/pending/views.lua

@@ -1,8 +1,7 @@
 local config = require('pending.config')
-local parse = require('pending.parse')
 
 ---@class pending.LineMeta
----@field type 'task'|'header'|'blank'|'filter'
+---@field type 'task'|'header'|'blank'
 ---@field id? integer
 ---@field due? string
 ---@field raw_due? string
@@ -11,7 +10,6 @@ local parse = require('pending.parse')
 ---@field overdue? boolean
 ---@field show_category? boolean
 ---@field priority? integer
----@field recur? string
 
 ---@class pending.views
 local M = {}
@@ -22,10 +20,7 @@ local function format_due(due)
   if not due then
     return nil
   end
-  local y, m, d, hh, mm = due:match('^(%d%d%d%d)-(%d%d)-(%d%d)T(%d%d):(%d%d)$')
+  local y, m, d = due:match('^(%d%d%d%d)-(%d%d)-(%d%d)$')
-  if not y then
-    y, m, d = due:match('^(%d%d%d%d)-(%d%d)-(%d%d)$')
-  end
   if not y then
     return due
   end
@@ -34,11 +29,7 @@ local function format_due(due)
     month = tonumber(m) --[[@as integer]],
     day = tonumber(d) --[[@as integer]],
   })
-  local formatted = os.date(config.get().date_format, t) --[[@as string]]
+  return os.date(config.get().date_format, t) --[[@as string]]
-  if hh then
-    formatted = formatted .. ' ' .. hh .. ':' .. mm
-  end
-  return formatted
 end
 
 ---@param tasks pending.Task[]
@@ -82,6 +73,7 @@ end
 ---@return string[] lines
 ---@return pending.LineMeta[] meta
 function M.category_view(tasks)
+  local today = os.date('%Y-%m-%d') --[[@as string]]
   local by_cat = {}
   local cat_order = {}
   local cat_seen = {}
@@ -133,7 +125,7 @@ function M.category_view(tasks)
       table.insert(lines, '')
       table.insert(meta, { type = 'blank' })
     end
-    table.insert(lines, '# ' .. cat)
+    table.insert(lines, '## ' .. cat)
     table.insert(meta, { type = 'header', category = cat })
 
     local all = {}
@@ -156,9 +148,7 @@ function M.category_view(tasks)
         raw_due = task.due,
         status = task.status,
         category = cat,
-        overdue = task.status == 'pending' and task.due ~= nil and parse.is_overdue(task.due)
+        overdue = task.status == 'pending' and task.due ~= nil and task.due < today or nil,
-          or nil,
-        recur = task.recur,
       })
     end
   end
@@ -170,6 +160,7 @@ end
 ---@return string[] lines
 ---@return pending.LineMeta[] meta
 function M.priority_view(tasks)
+  local today = os.date('%Y-%m-%d') --[[@as string]]
   local pending = {}
   local done = {}
 
@@ -207,9 +198,8 @@ function M.priority_view(tasks)
       raw_due = task.due,
       status = task.status,
       category = task.category,
-      overdue = task.status == 'pending' and task.due ~= nil and parse.is_overdue(task.due) or nil,
+      overdue = task.status == 'pending' and task.due ~= nil and task.due < today or nil,
       show_category = true,
-      recur = task.recur,
     })
   end
 

plugin/pending.lua

@@ -3,235 +3,16 @@ if vim.g.loaded_pending then
 end
 vim.g.loaded_pending = true
 
----@return string[]
-local function edit_field_candidates()
-  local cfg = require('pending.config').get()
-  local dk = cfg.date_syntax or 'due'
-  local rk = cfg.recur_syntax or 'rec'
-  return {
-    dk .. ':',
-    'cat:',
-    rk .. ':',
-    '+!',
-    '-!',
-    '-' .. dk,
-    '-cat',
-    '-' .. rk,
-  }
-end
-
----@return string[]
-local function edit_date_values()
-  return {
-    'today',
-    'tomorrow',
-    'yesterday',
-    '+1d',
-    '+2d',
-    '+3d',
-    '+1w',
-    '+2w',
-    '+1m',
-    'mon',
-    'tue',
-    'wed',
-    'thu',
-    'fri',
-    'sat',
-    'sun',
-    'eod',
-    'eow',
-    'eom',
-    'eoq',
-    'eoy',
-    'sow',
-    'som',
-    'soq',
-    'soy',
-    'later',
-  }
-end
-
----@return string[]
-local function edit_recur_values()
-  local ok, recur = pcall(require, 'pending.recur')
-  if not ok then
-    return {}
-  end
-  local result = {}
-  for _, s in ipairs(recur.shorthand_list()) do
-    table.insert(result, s)
-  end
-  for _, s in ipairs(recur.shorthand_list()) do
-    table.insert(result, '!' .. s)
-  end
-  return result
-end
-
----@param lead string
----@param candidates string[]
----@return string[]
-local function filter_candidates(lead, candidates)
-  return vim.tbl_filter(function(s)
-    return s:find(lead, 1, true) == 1
-  end, candidates)
-end
-
----@param arg_lead string
----@param cmd_line string
----@return string[]
-local function complete_edit(arg_lead, cmd_line)
-  local cfg = require('pending.config').get()
-  local dk = cfg.date_syntax or 'due'
-  local rk = cfg.recur_syntax or 'rec'
-
-  local after_edit = cmd_line:match('^Pending%s+edit%s+(.*)')
-  if not after_edit then
-    return {}
-  end
-
-  local parts = {}
-  for part in after_edit:gmatch('%S+') do
-    table.insert(parts, part)
-  end
-
-  local trailing_space = after_edit:match('%s$')
-  if #parts == 0 or (#parts == 1 and not trailing_space) then
-    local store = require('pending.store')
-    local s = store.new(store.resolve_path())
-    s:load()
-    local ids = {}
-    for _, task in ipairs(s:active_tasks()) do
-      table.insert(ids, tostring(task.id))
-    end
-    return filter_candidates(arg_lead, ids)
-  end
-
-  local prefix = arg_lead:match('^(' .. vim.pesc(dk) .. ':)(.*)$')
-  if prefix then
-    local after_colon = arg_lead:sub(#prefix + 1)
-    local dates = edit_date_values()
-    local result = {}
-    for _, d in ipairs(dates) do
-      if d:find(after_colon, 1, true) == 1 then
-        table.insert(result, prefix .. d)
-      end
-    end
-    return result
-  end
-
-  local rec_prefix = arg_lead:match('^(' .. vim.pesc(rk) .. ':)(.*)$')
-  if rec_prefix then
-    local after_colon = arg_lead:sub(#rec_prefix + 1)
-    local pats = edit_recur_values()
-    local result = {}
-    for _, p in ipairs(pats) do
-      if p:find(after_colon, 1, true) == 1 then
-        table.insert(result, rec_prefix .. p)
-      end
-    end
-    return result
-  end
-
-  local cat_prefix = arg_lead:match('^(cat:)(.*)$')
-  if cat_prefix then
-    local after_colon = arg_lead:sub(#cat_prefix + 1)
-    local store = require('pending.store')
-    local s = store.new(store.resolve_path())
-    s:load()
-    local seen = {}
-    local cats = {}
-    for _, task in ipairs(s:active_tasks()) do
-      if task.category and not seen[task.category] then
-        seen[task.category] = true
-        table.insert(cats, task.category)
-      end
-    end
-    table.sort(cats)
-    local result = {}
-    for _, c in ipairs(cats) do
-      if c:find(after_colon, 1, true) == 1 then
-        table.insert(result, cat_prefix .. c)
-      end
-    end
-    return result
-  end
-
-  return filter_candidates(arg_lead, edit_field_candidates())
-end
-
 vim.api.nvim_create_user_command('Pending', function(opts)
   require('pending').command(opts.args)
 end, {
-  bar = true,
   nargs = '*',
   complete = function(arg_lead, cmd_line)
-    local pending = require('pending')
+    local subcmds = { 'add', 'sync', 'archive', 'due', 'undo' }
-    local subcmds = { 'add', 'archive', 'auth', 'done', 'due', 'edit', 'filter', 'undo' }
-    for _, b in ipairs(pending.sync_backends()) do
-      table.insert(subcmds, b)
-    end
-    table.sort(subcmds)
     if not cmd_line:match('^Pending%s+%S') then
-      return filter_candidates(arg_lead, subcmds)
+      return vim.tbl_filter(function(s)
-    end
+        return s:find(arg_lead, 1, true) == 1
-    if cmd_line:match('^Pending%s+filter') then
+      end, subcmds)
-      local after_filter = cmd_line:match('^Pending%s+filter%s+(.*)') or ''
-      local used = {}
-      for word in after_filter:gmatch('%S+') do
-        used[word] = true
-      end
-      local candidates = { 'clear', 'overdue', 'today', 'priority', 'done', 'pending' }
-      local store = require('pending.store')
-      local s = store.new(store.resolve_path())
-      s:load()
-      local seen = {}
-      for _, task in ipairs(s:active_tasks()) do
-        if task.category and not seen[task.category] then
-          seen[task.category] = true
-          table.insert(candidates, 'cat:' .. task.category)
-        end
-      end
-      local filtered = {}
-      for _, c in ipairs(candidates) do
-        if not used[c] and (arg_lead == '' or c:find(arg_lead, 1, true) == 1) then
-          table.insert(filtered, c)
-        end
-      end
-      return filtered
-    end
-    if cmd_line:match('^Pending%s+done%s') then
-      local store = require('pending.store')
-      local s = store.new(store.resolve_path())
-      s:load()
-      local ids = {}
-      for _, task in ipairs(s:active_tasks()) do
-        table.insert(ids, tostring(task.id))
-      end
-      return filter_candidates(arg_lead, ids)
-    end
-    if cmd_line:match('^Pending%s+edit') then
-      return complete_edit(arg_lead, cmd_line)
-    end
-    local backend_set = pending.sync_backend_set()
-    local matched_backend = cmd_line:match('^Pending%s+(%S+)')
-    if matched_backend and backend_set[matched_backend] then
-      local after_backend = cmd_line:match('^Pending%s+%S+%s+(.*)')
-      if not after_backend then
-        return {}
-      end
-      local ok, mod = pcall(require, 'pending.sync.' .. matched_backend)
-      if not ok then
-        return {}
-      end
-      local actions = {}
-      for k, v in pairs(mod) do
-        if type(v) == 'function' and k:sub(1, 1) ~= '_' and k ~= 'health' then
-          table.insert(actions, k)
-        end
-      end
-      table.sort(actions)
-      return filter_candidates(arg_lead, actions)
     end
     return {}
   end,
@@ -241,10 +22,6 @@ vim.keymap.set('n', '<Plug>(pending-open)', function()
   require('pending').open()
 end)
 
-vim.keymap.set('n', '<Plug>(pending-close)', function()
-  require('pending.buffer').close()
-end)
-
 vim.keymap.set('n', '<Plug>(pending-toggle)', function()
   require('pending').toggle_complete()
 end)
@@ -260,65 +37,3 @@ end)
 vim.keymap.set('n', '<Plug>(pending-date)', function()
   require('pending').prompt_date()
 end)
-
-vim.keymap.set('n', '<Plug>(pending-undo)', function()
-  require('pending').undo_write()
-end)
-
-vim.keymap.set('n', '<Plug>(pending-filter)', function()
-  vim.ui.input({ prompt = 'Filter: ' }, function(input)
-    if input then
-      require('pending').filter(input)
-    end
-  end)
-end)
-
-vim.keymap.set('n', '<Plug>(pending-open-line)', function()
-  require('pending.buffer').open_line(false)
-end)
-
-vim.keymap.set('n', '<Plug>(pending-open-line-above)', function()
-  require('pending.buffer').open_line(true)
-end)
-
-vim.keymap.set({ 'o', 'x' }, '<Plug>(pending-a-task)', function()
-  require('pending.textobj').a_task(vim.v.count1)
-end)
-
-vim.keymap.set({ 'o', 'x' }, '<Plug>(pending-i-task)', function()
-  require('pending.textobj').i_task(vim.v.count1)
-end)
-
-vim.keymap.set({ 'o', 'x' }, '<Plug>(pending-a-category)', function()
-  require('pending.textobj').a_category(vim.v.count1)
-end)
-
-vim.keymap.set({ 'o', 'x' }, '<Plug>(pending-i-category)', function()
-  require('pending.textobj').i_category(vim.v.count1)
-end)
-
-vim.keymap.set({ 'n', 'x', 'o' }, '<Plug>(pending-next-header)', function()
-  require('pending.textobj').next_header(vim.v.count1)
-end)
-
-vim.keymap.set({ 'n', 'x', 'o' }, '<Plug>(pending-prev-header)', function()
-  require('pending.textobj').prev_header(vim.v.count1)
-end)
-
-vim.keymap.set({ 'n', 'x', 'o' }, '<Plug>(pending-next-task)', function()
-  require('pending.textobj').next_task(vim.v.count1)
-end)
-
-vim.keymap.set({ 'n', 'x', 'o' }, '<Plug>(pending-prev-task)', function()
-  require('pending.textobj').prev_task(vim.v.count1)
-end)
-
-vim.keymap.set('n', '<Plug>(pending-tab)', function()
-  vim.cmd.tabnew()
-  require('pending').open()
-end)
-
-vim.api.nvim_create_user_command('PendingTab', function()
-  vim.cmd.tabnew()
-  require('pending').open()
-end, {})

scripts/ci.sh

@@ -1,10 +0,0 @@
-#!/bin/sh
-set -eu
-
-nix develop --command stylua --check .
-git ls-files '*.lua' | xargs nix develop --command selene --display-style quiet
-nix develop --command prettier --check .
-nix fmt
-git diff --exit-code -- '*.nix'
-nix develop --command lua-language-server --check lua --configpath "$(pwd)/.luarc.json" --checklevel=Warning
-nix develop --command busted

spec/archive_spec.lua

@@ -1,96 +1,87 @@
 require('spec.helpers')
 
 local config = require('pending.config')
+local store = require('pending.store')
 
 describe('archive', function()
   local tmpdir
-  local pending
+  local pending = require('pending')
 
   before_each(function()
     tmpdir = vim.fn.tempname()
     vim.fn.mkdir(tmpdir, 'p')
     vim.g.pending = { data_path = tmpdir .. '/tasks.json' }
     config.reset()
-    package.loaded['pending'] = nil
+    store.unload()
-    pending = require('pending')
+    store.load()
-    pending.store():load()
   end)
 
   after_each(function()
     vim.fn.delete(tmpdir, 'rf')
     vim.g.pending = nil
     config.reset()
-    package.loaded['pending'] = nil
   end)
 
   it('removes done tasks completed more than 30 days ago', function()
-    local s = pending.store()
+    local t = store.add({ description = 'Old done task' })
-    local t = s:add({ description = 'Old done task' })
+    store.update(t.id, { status = 'done', ['end'] = '2020-01-01T00:00:00Z' })
-    s:update(t.id, { status = 'done', ['end'] = '2020-01-01T00:00:00Z' })
     pending.archive()
-    assert.are.equal(0, #s:active_tasks())
+    assert.are.equal(0, #store.active_tasks())
   end)
 
   it('keeps done tasks completed fewer than 30 days ago', function()
-    local s = pending.store()
     local recent_end = os.date('!%Y-%m-%dT%H:%M:%SZ', os.time() - (5 * 86400))
-    local t = s:add({ description = 'Recent done task' })
+    local t = store.add({ description = 'Recent done task' })
-    s:update(t.id, { status = 'done', ['end'] = recent_end })
+    store.update(t.id, { status = 'done', ['end'] = recent_end })
     pending.archive()
-    local active = s:active_tasks()
+    local active = store.active_tasks()
     assert.are.equal(1, #active)
     assert.are.equal('Recent done task', active[1].description)
   end)
 
   it('respects a custom day count', function()
-    local s = pending.store()
     local eight_days_ago = os.date('!%Y-%m-%dT%H:%M:%SZ', os.time() - (8 * 86400))
-    local t = s:add({ description = 'Old for 7 days' })
+    local t = store.add({ description = 'Old for 7 days' })
-    s:update(t.id, { status = 'done', ['end'] = eight_days_ago })
+    store.update(t.id, { status = 'done', ['end'] = eight_days_ago })
     pending.archive(7)
-    assert.are.equal(0, #s:active_tasks())
+    assert.are.equal(0, #store.active_tasks())
   end)
 
   it('keeps tasks within the custom day cutoff', function()
-    local s = pending.store()
     local five_days_ago = os.date('!%Y-%m-%dT%H:%M:%SZ', os.time() - (5 * 86400))
-    local t = s:add({ description = 'Recent for 7 days' })
+    local t = store.add({ description = 'Recent for 7 days' })
-    s:update(t.id, { status = 'done', ['end'] = five_days_ago })
+    store.update(t.id, { status = 'done', ['end'] = five_days_ago })
     pending.archive(7)
-    local active = s:active_tasks()
+    local active = store.active_tasks()
     assert.are.equal(1, #active)
   end)
 
   it('never archives pending tasks regardless of age', function()
-    local s = pending.store()
+    store.add({ description = 'Still pending' })
-    s:add({ description = 'Still pending' })
     pending.archive()
-    local active = s:active_tasks()
+    local active = store.active_tasks()
     assert.are.equal(1, #active)
     assert.are.equal('pending', active[1].status)
   end)
 
   it('removes deleted tasks past the cutoff', function()
-    local s = pending.store()
+    local t = store.add({ description = 'Old deleted task' })
-    local t = s:add({ description = 'Old deleted task' })
+    store.update(t.id, { status = 'deleted', ['end'] = '2020-01-01T00:00:00Z' })
-    s:update(t.id, { status = 'deleted', ['end'] = '2020-01-01T00:00:00Z' })
     pending.archive()
-    local all = s:tasks()
+    local all = store.tasks()
     assert.are.equal(0, #all)
   end)
 
   it('keeps deleted tasks within the cutoff', function()
-    local s = pending.store()
     local recent_end = os.date('!%Y-%m-%dT%H:%M:%SZ', os.time() - (5 * 86400))
-    local t = s:add({ description = 'Recent deleted' })
+    local t = store.add({ description = 'Recent deleted' })
-    s:update(t.id, { status = 'deleted', ['end'] = recent_end })
+    store.update(t.id, { status = 'deleted', ['end'] = recent_end })
     pending.archive()
-    local all = s:tasks()
+    local all = store.tasks()
     assert.are.equal(1, #all)
   end)
 
   it('reports the correct count in vim.notify', function()
-    local s = pending.store()
     local messages = {}
     local orig_notify = vim.notify
     vim.notify = function(msg, ...)
@@ -98,11 +89,11 @@ describe('archive', function()
       return orig_notify(msg, ...)
     end
 
-    local t1 = s:add({ description = 'Old 1' })
+    local t1 = store.add({ description = 'Old 1' })
-    local t2 = s:add({ description = 'Old 2' })
+    local t2 = store.add({ description = 'Old 2' })
-    s:add({ description = 'Keep' })
+    store.add({ description = 'Keep' })
-    s:update(t1.id, { status = 'done', ['end'] = '2020-01-01T00:00:00Z' })
+    store.update(t1.id, { status = 'done', ['end'] = '2020-01-01T00:00:00Z' })
-    s:update(t2.id, { status = 'done', ['end'] = '2020-01-01T00:00:00Z' })
+    store.update(t2.id, { status = 'done', ['end'] = '2020-01-01T00:00:00Z' })
 
     pending.archive()
 
@@ -119,17 +110,16 @@ describe('archive', function()
   end)
 
   it('leaves only kept tasks in store.active_tasks after archive', function()
-    local s = pending.store()
+    local t1 = store.add({ description = 'Old done' })
-    local t1 = s:add({ description = 'Old done' })
+    store.add({ description = 'Keep pending' })
-    s:add({ description = 'Keep pending' })
     local recent_end = os.date('!%Y-%m-%dT%H:%M:%SZ', os.time() - (5 * 86400))
-    local t3 = s:add({ description = 'Keep recent done' })
+    local t3 = store.add({ description = 'Keep recent done' })
-    s:update(t1.id, { status = 'done', ['end'] = '2020-01-01T00:00:00Z' })
+    store.update(t1.id, { status = 'done', ['end'] = '2020-01-01T00:00:00Z' })
-    s:update(t3.id, { status = 'done', ['end'] = recent_end })
+    store.update(t3.id, { status = 'done', ['end'] = recent_end })
 
     pending.archive()
 
-    local active = s:active_tasks()
+    local active = store.active_tasks()
     assert.are.equal(2, #active)
     local descs = {}
     for _, task in ipairs(active) do
@@ -140,11 +130,11 @@ describe('archive', function()
   end)
 
   it('persists archived tasks to disk after unload/reload', function()
-    local s = pending.store()
+    local t = store.add({ description = 'Archived task' })
-    local t = s:add({ description = 'Archived task' })
+    store.update(t.id, { status = 'done', ['end'] = '2020-01-01T00:00:00Z' })
-    s:update(t.id, { status = 'done', ['end'] = '2020-01-01T00:00:00Z' })
     pending.archive()
-    s:load()
+    store.unload()
-    assert.are.equal(0, #s:active_tasks())
+    store.load()
+    assert.are.equal(0, #store.active_tasks())
   end)
 end)

spec/complete_spec.lua

@@ -1,173 +0,0 @@
-require('spec.helpers')
-
-local buffer = require('pending.buffer')
-local config = require('pending.config')
-local store = require('pending.store')
-
-describe('complete', function()
-  local tmpdir
-  local s
-  local complete = require('pending.complete')
-
-  before_each(function()
-    tmpdir = vim.fn.tempname()
-    vim.fn.mkdir(tmpdir, 'p')
-    config.reset()
-    s = store.new(tmpdir .. '/tasks.json')
-    s:load()
-    buffer.set_store(s)
-  end)
-
-  after_each(function()
-    vim.fn.delete(tmpdir, 'rf')
-    config.reset()
-    buffer.set_store(nil)
-  end)
-
-  describe('findstart', function()
-    it('returns column after colon for cat: prefix', function()
-      local bufnr = vim.api.nvim_create_buf(false, true)
-      vim.api.nvim_buf_set_lines(bufnr, 0, -1, false, { '- [ ] task cat:Wo' })
-      vim.api.nvim_set_current_buf(bufnr)
-      vim.api.nvim_win_set_cursor(0, { 1, 16 })
-      local result = complete.omnifunc(1, '')
-      assert.are.equal(15, result)
-      vim.api.nvim_buf_delete(bufnr, { force = true })
-    end)
-
-    it('returns column after colon for due: prefix', function()
-      local bufnr = vim.api.nvim_create_buf(false, true)
-      vim.api.nvim_buf_set_lines(bufnr, 0, -1, false, { '- [ ] task due:to' })
-      vim.api.nvim_set_current_buf(bufnr)
-      vim.api.nvim_win_set_cursor(0, { 1, 16 })
-      local result = complete.omnifunc(1, '')
-      assert.are.equal(15, result)
-      vim.api.nvim_buf_delete(bufnr, { force = true })
-    end)
-
-    it('returns column after colon for rec: prefix', function()
-      local bufnr = vim.api.nvim_create_buf(false, true)
-      vim.api.nvim_buf_set_lines(bufnr, 0, -1, false, { '- [ ] task rec:we' })
-      vim.api.nvim_set_current_buf(bufnr)
-      vim.api.nvim_win_set_cursor(0, { 1, 16 })
-      local result = complete.omnifunc(1, '')
-      assert.are.equal(15, result)
-      vim.api.nvim_buf_delete(bufnr, { force = true })
-    end)
-
-    it('returns -1 for non-token position', function()
-      local bufnr = vim.api.nvim_create_buf(false, true)
-      vim.api.nvim_buf_set_lines(bufnr, 0, -1, false, { '- [ ] some task ' })
-      vim.api.nvim_set_current_buf(bufnr)
-      vim.api.nvim_win_set_cursor(0, { 1, 14 })
-      local result = complete.omnifunc(1, '')
-      assert.are.equal(-1, result)
-      vim.api.nvim_buf_delete(bufnr, { force = true })
-    end)
-  end)
-
-  describe('completions', function()
-    it('returns existing categories for cat:', function()
-      s:add({ description = 'A', category = 'Work' })
-      s:add({ description = 'B', category = 'Home' })
-      s:add({ description = 'C', category = 'Work' })
-      local bufnr = vim.api.nvim_create_buf(false, true)
-      vim.api.nvim_buf_set_lines(bufnr, 0, -1, false, { '- [ ] task cat: x' })
-      vim.api.nvim_set_current_buf(bufnr)
-      vim.api.nvim_win_set_cursor(0, { 1, 15 })
-      complete.omnifunc(1, '')
-      local result = complete.omnifunc(0, '')
-      local words = {}
-      for _, item in ipairs(result) do
-        table.insert(words, item.word)
-      end
-      assert.is_true(vim.tbl_contains(words, 'Work'))
-      assert.is_true(vim.tbl_contains(words, 'Home'))
-      vim.api.nvim_buf_delete(bufnr, { force = true })
-    end)
-
-    it('filters categories by base', function()
-      s:add({ description = 'A', category = 'Work' })
-      s:add({ description = 'B', category = 'Home' })
-      local bufnr = vim.api.nvim_create_buf(false, true)
-      vim.api.nvim_buf_set_lines(bufnr, 0, -1, false, { '- [ ] task cat:W' })
-      vim.api.nvim_set_current_buf(bufnr)
-      vim.api.nvim_win_set_cursor(0, { 1, 15 })
-      complete.omnifunc(1, '')
-      local result = complete.omnifunc(0, 'W')
-      assert.are.equal(1, #result)
-      assert.are.equal('Work', result[1].word)
-      vim.api.nvim_buf_delete(bufnr, { force = true })
-    end)
-
-    it('returns named dates for due:', function()
-      local bufnr = vim.api.nvim_create_buf(false, true)
-      vim.api.nvim_buf_set_lines(bufnr, 0, -1, false, { '- [ ] task due: x' })
-      vim.api.nvim_set_current_buf(bufnr)
-      vim.api.nvim_win_set_cursor(0, { 1, 15 })
-      complete.omnifunc(1, '')
-      local result = complete.omnifunc(0, '')
-      assert.is_true(#result > 0)
-      local words = {}
-      for _, item in ipairs(result) do
-        table.insert(words, item.word)
-      end
-      assert.is_true(vim.tbl_contains(words, 'today'))
-      assert.is_true(vim.tbl_contains(words, 'tomorrow'))
-      assert.is_true(vim.tbl_contains(words, 'eom'))
-      vim.api.nvim_buf_delete(bufnr, { force = true })
-    end)
-
-    it('filters dates by base prefix', function()
-      local bufnr = vim.api.nvim_create_buf(false, true)
-      vim.api.nvim_buf_set_lines(bufnr, 0, -1, false, { '- [ ] task due:to' })
-      vim.api.nvim_set_current_buf(bufnr)
-      vim.api.nvim_win_set_cursor(0, { 1, 16 })
-      complete.omnifunc(1, '')
-      local result = complete.omnifunc(0, 'to')
-      local words = {}
-      for _, item in ipairs(result) do
-        table.insert(words, item.word)
-      end
-      assert.is_true(vim.tbl_contains(words, 'today'))
-      assert.is_true(vim.tbl_contains(words, 'tomorrow'))
-      assert.is_false(vim.tbl_contains(words, 'eom'))
-      vim.api.nvim_buf_delete(bufnr, { force = true })
-    end)
-
-    it('returns recurrence shorthands for rec:', function()
-      local bufnr = vim.api.nvim_create_buf(false, true)
-      vim.api.nvim_buf_set_lines(bufnr, 0, -1, false, { '- [ ] task rec: x' })
-      vim.api.nvim_set_current_buf(bufnr)
-      vim.api.nvim_win_set_cursor(0, { 1, 15 })
-      complete.omnifunc(1, '')
-      local result = complete.omnifunc(0, '')
-      assert.is_true(#result > 0)
-      local words = {}
-      for _, item in ipairs(result) do
-        table.insert(words, item.word)
-      end
-      assert.is_true(vim.tbl_contains(words, 'daily'))
-      assert.is_true(vim.tbl_contains(words, 'weekly'))
-      assert.is_true(vim.tbl_contains(words, '!weekly'))
-      vim.api.nvim_buf_delete(bufnr, { force = true })
-    end)
-
-    it('filters recurrence by base prefix', function()
-      local bufnr = vim.api.nvim_create_buf(false, true)
-      vim.api.nvim_buf_set_lines(bufnr, 0, -1, false, { '- [ ] task rec:we' })
-      vim.api.nvim_set_current_buf(bufnr)
-      vim.api.nvim_win_set_cursor(0, { 1, 16 })
-      complete.omnifunc(1, '')
-      local result = complete.omnifunc(0, 'we')
-      local words = {}
-      for _, item in ipairs(result) do
-        table.insert(words, item.word)
-      end
-      assert.is_true(vim.tbl_contains(words, 'weekly'))
-      assert.is_true(vim.tbl_contains(words, 'weekdays'))
-      assert.is_false(vim.tbl_contains(words, 'daily'))
-      vim.api.nvim_buf_delete(bufnr, { force = true })
-    end)
-  end)
-end)

spec/diff_spec.lua

@@ -1,31 +1,35 @@
 require('spec.helpers')
 
+local config = require('pending.config')
 local store = require('pending.store')
 
 describe('diff', function()
   local tmpdir
-  local s
   local diff = require('pending.diff')
 
   before_each(function()
     tmpdir = vim.fn.tempname()
     vim.fn.mkdir(tmpdir, 'p')
-    s = store.new(tmpdir .. '/tasks.json')
+    vim.g.pending = { data_path = tmpdir .. '/tasks.json' }
-    s:load()
+    config.reset()
+    store.unload()
+    store.load()
   end)
 
   after_each(function()
     vim.fn.delete(tmpdir, 'rf')
+    vim.g.pending = nil
+    config.reset()
   end)
 
   describe('parse_buffer', function()
     it('parses headers and tasks', function()
       local lines = {
-        '# School',
+        '## School',
         '/1/- [ ] Do homework',
         '/2/- [!] Read chapter 5',
         '',
-        '# Errands',
+        '## Errands',
         '/3/- [ ] Buy groceries',
       }
       local result = diff.parse_buffer(lines)
@@ -44,7 +48,7 @@ describe('diff', function()
 
     it('handles new tasks without ids', function()
       local lines = {
-        '# Inbox',
+        '## Inbox',
         '- [ ] New task here',
       }
       local result = diff.parse_buffer(lines)
@@ -56,7 +60,7 @@ describe('diff', function()
 
     it('inline cat: token overrides header category', function()
       local lines = {
-        '# Inbox',
+        '## Inbox',
         '/1/- [ ] Buy milk cat:Work',
       }
       local result = diff.parse_buffer(lines)
@@ -65,28 +69,9 @@ describe('diff', function()
       assert.are.equal('Work', result[2].category)
     end)
 
-    it('extracts rec: token from buffer line', function()
-      local lines = {
-        '# Inbox',
-        '/1/- [ ] Take trash out rec:weekly',
-      }
-      local result = diff.parse_buffer(lines)
-      assert.are.equal('weekly', result[2].rec)
-    end)
-
-    it('extracts rec: with completion mode', function()
-      local lines = {
-        '# Inbox',
-        '/1/- [ ] Water plants rec:!daily',
-      }
-      local result = diff.parse_buffer(lines)
-      assert.are.equal('daily', result[2].rec)
-      assert.are.equal('completion', result[2].rec_mode)
-    end)
-
     it('inline due: token is parsed', function()
       local lines = {
-        '# Inbox',
+        '## Inbox',
         '/1/- [ ] Buy milk due:2026-03-15',
       }
       local result = diff.parse_buffer(lines)
@@ -99,192 +84,139 @@ describe('diff', function()
   describe('apply', function()
     it('creates new tasks from buffer lines', function()
       local lines = {
-        '# Inbox',
+        '## Inbox',
         '- [ ] First task',
         '- [ ] Second task',
       }
-      diff.apply(lines, s)
+      diff.apply(lines)
-      s:load()
+      store.unload()
-      local tasks = s:active_tasks()
+      store.load()
+      local tasks = store.active_tasks()
       assert.are.equal(2, #tasks)
       assert.are.equal('First task', tasks[1].description)
       assert.are.equal('Second task', tasks[2].description)
     end)
 
     it('deletes tasks removed from buffer', function()
-      s:add({ description = 'Keep me' })
+      store.add({ description = 'Keep me' })
-      s:add({ description = 'Delete me' })
+      store.add({ description = 'Delete me' })
-      s:save()
+      store.save()
       local lines = {
-        '# Inbox',
+        '## Inbox',
         '/1/- [ ] Keep me',
       }
-      diff.apply(lines, s)
+      diff.apply(lines)
-      s:load()
+      store.unload()
-      local active = s:active_tasks()
+      store.load()
+      local active = store.active_tasks()
       assert.are.equal(1, #active)
       assert.are.equal('Keep me', active[1].description)
-      local deleted = s:get(2)
+      local deleted = store.get(2)
       assert.are.equal('deleted', deleted.status)
     end)
 
     it('updates modified tasks', function()
-      s:add({ description = 'Original' })
+      store.add({ description = 'Original' })
-      s:save()
+      store.save()
       local lines = {
-        '# Inbox',
+        '## Inbox',
         '/1/- [ ] Renamed',
       }
-      diff.apply(lines, s)
+      diff.apply(lines)
-      s:load()
+      store.unload()
-      local task = s:get(1)
+      store.load()
+      local task = store.get(1)
       assert.are.equal('Renamed', task.description)
     end)
 
     it('updates modified when description is renamed', function()
-      local t = s:add({ description = 'Original', category = 'Inbox' })
+      local t = store.add({ description = 'Original', category = 'Inbox' })
       t.modified = '2020-01-01T00:00:00Z'
-      s:save()
+      store.save()
       local lines = {
-        '# Inbox',
+        '## Inbox',
         '/1/- [ ] Renamed',
       }
-      diff.apply(lines, s)
+      diff.apply(lines)
-      s:load()
+      store.unload()
-      local task = s:get(1)
+      store.load()
+      local task = store.get(1)
       assert.are.equal('Renamed', task.description)
       assert.is_not.equal('2020-01-01T00:00:00Z', task.modified)
     end)
 
     it('handles duplicate ids as copies', function()
-      s:add({ description = 'Original' })
+      store.add({ description = 'Original' })
-      s:save()
+      store.save()
       local lines = {
-        '# Inbox',
+        '## Inbox',
         '/1/- [ ] Original',
         '/1/- [ ] Copy of original',
       }
-      diff.apply(lines, s)
+      diff.apply(lines)
-      s:load()
+      store.unload()
-      local tasks = s:active_tasks()
+      store.load()
+      local tasks = store.active_tasks()
       assert.are.equal(2, #tasks)
     end)
 
     it('moves tasks between categories', function()
-      s:add({ description = 'Moving task', category = 'Inbox' })
+      store.add({ description = 'Moving task', category = 'Inbox' })
-      s:save()
+      store.save()
       local lines = {
-        '# Work',
+        '## Work',
         '/1/- [ ] Moving task',
       }
-      diff.apply(lines, s)
+      diff.apply(lines)
-      s:load()
+      store.unload()
-      local task = s:get(1)
+      store.load()
+      local task = store.get(1)
       assert.are.equal('Work', task.category)
     end)
 
     it('does not update modified when task is unchanged', function()
-      s:add({ description = 'Stable task', category = 'Inbox' })
+      store.add({ description = 'Stable task', category = 'Inbox' })
-      s:save()
+      store.save()
       local lines = {
-        '# Inbox',
+        '## Inbox',
         '/1/- [ ] Stable task',
       }
-      diff.apply(lines, s)
+      diff.apply(lines)
-      s:load()
+      store.unload()
-      local modified_after_first = s:get(1).modified
+      store.load()
-      diff.apply(lines, s)
+      local modified_after_first = store.get(1).modified
-      s:load()
+      diff.apply(lines)
-      local task = s:get(1)
+      store.unload()
+      store.load()
+      local task = store.get(1)
       assert.are.equal(modified_after_first, task.modified)
     end)
 
-    it('preserves due when not present in buffer line', function()
+    it('clears due when removed from buffer line', function()
-      s:add({ description = 'Pay bill', due = '2026-03-15' })
+      store.add({ description = 'Pay bill', due = '2026-03-15' })
-      s:save()
+      store.save()
       local lines = {
-        '# Inbox',
+        '## Inbox',
         '/1/- [ ] Pay bill',
       }
-      diff.apply(lines, s)
+      diff.apply(lines)
-      s:load()
+      store.unload()
-      local task = s:get(1)
+      store.load()
-      assert.are.equal('2026-03-15', task.due)
+      local task = store.get(1)
-    end)
+      assert.is_nil(task.due)
-
-    it('updates due when inline token is present', function()
-      s:add({ description = 'Pay bill', due = '2026-03-15' })
-      s:save()
-      local lines = {
-        '# Inbox',
-        '/1/- [ ] Pay bill due:2026-04-01',
-      }
-      diff.apply(lines, s)
-      s:load()
-      local task = s:get(1)
-      assert.are.equal('2026-04-01', task.due)
-    end)
-
-    it('stores recur field on new tasks from buffer', function()
-      local lines = {
-        '# Inbox',
-        '- [ ] Take out trash rec:weekly',
-      }
-      diff.apply(lines, s)
-      s:load()
-      local tasks = s:active_tasks()
-      assert.are.equal(1, #tasks)
-      assert.are.equal('weekly', tasks[1].recur)
-    end)
-
-    it('updates recur field when changed inline', function()
-      s:add({ description = 'Task', recur = 'daily' })
-      s:save()
-      local lines = {
-        '# Todo',
-        '/1/- [ ] Task rec:weekly',
-      }
-      diff.apply(lines, s)
-      s:load()
-      local task = s:get(1)
-      assert.are.equal('weekly', task.recur)
-    end)
-
-    it('preserves recur when not present in buffer line', function()
-      s:add({ description = 'Task', recur = 'daily' })
-      s:save()
-      local lines = {
-        '# Todo',
-        '/1/- [ ] Task',
-      }
-      diff.apply(lines, s)
-      s:load()
-      local task = s:get(1)
-      assert.are.equal('daily', task.recur)
-    end)
-
-    it('parses rec: with completion mode prefix', function()
-      local lines = {
-        '# Inbox',
-        '- [ ] Water plants rec:!weekly',
-      }
-      diff.apply(lines, s)
-      s:load()
-      local tasks = s:active_tasks()
-      assert.are.equal('weekly', tasks[1].recur)
-      assert.are.equal('completion', tasks[1].recur_mode)
     end)
 
     it('clears priority when [N] is removed from buffer line', function()
-      s:add({ description = 'Task name', priority = 1 })
+      store.add({ description = 'Task name', priority = 1 })
-      s:save()
+      store.save()
       local lines = {
-        '# Inbox',
+        '## Inbox',
         '/1/- [ ] Task name',
       }
-      diff.apply(lines, s)
+      diff.apply(lines)
-      s:load()
+      store.unload()
-      local task = s:get(1)
+      store.load()
+      local task = store.get(1)
       assert.are.equal(0, task.priority)
     end)
   end)

spec/edit_spec.lua

@@ -1,329 +0,0 @@
-require('spec.helpers')
-
-local config = require('pending.config')
-
-describe('edit', function()
-  local tmpdir
-  local pending
-
-  before_each(function()
-    tmpdir = vim.fn.tempname()
-    vim.fn.mkdir(tmpdir, 'p')
-    vim.g.pending = { data_path = tmpdir .. '/tasks.json' }
-    config.reset()
-    package.loaded['pending'] = nil
-    pending = require('pending')
-    pending.store():load()
-  end)
-
-  after_each(function()
-    vim.fn.delete(tmpdir, 'rf')
-    vim.g.pending = nil
-    config.reset()
-    package.loaded['pending'] = nil
-  end)
-
-  it('sets due date with resolve_date vocabulary', function()
-    local s = pending.store()
-    local t = s:add({ description = 'Task one' })
-    s:save()
-    pending.edit(tostring(t.id), 'due:tomorrow')
-    local updated = s:get(t.id)
-    local today = os.date('*t') --[[@as osdate]]
-    local expected =
-      os.date('%Y-%m-%d', os.time({ year = today.year, month = today.month, day = today.day + 1 }))
-    assert.are.equal(expected, updated.due)
-  end)
-
-  it('sets due date with literal YYYY-MM-DD', function()
-    local s = pending.store()
-    local t = s:add({ description = 'Task one' })
-    s:save()
-    pending.edit(tostring(t.id), 'due:2026-06-15')
-    local updated = s:get(t.id)
-    assert.are.equal('2026-06-15', updated.due)
-  end)
-
-  it('sets category', function()
-    local s = pending.store()
-    local t = s:add({ description = 'Task one' })
-    s:save()
-    pending.edit(tostring(t.id), 'cat:Work')
-    local updated = s:get(t.id)
-    assert.are.equal('Work', updated.category)
-  end)
-
-  it('adds priority', function()
-    local s = pending.store()
-    local t = s:add({ description = 'Task one' })
-    s:save()
-    pending.edit(tostring(t.id), '+!')
-    local updated = s:get(t.id)
-    assert.are.equal(1, updated.priority)
-  end)
-
-  it('removes priority', function()
-    local s = pending.store()
-    local t = s:add({ description = 'Task one', priority = 1 })
-    s:save()
-    pending.edit(tostring(t.id), '-!')
-    local updated = s:get(t.id)
-    assert.are.equal(0, updated.priority)
-  end)
-
-  it('removes due date', function()
-    local s = pending.store()
-    local t = s:add({ description = 'Task one', due = '2026-06-15' })
-    s:save()
-    pending.edit(tostring(t.id), '-due')
-    local updated = s:get(t.id)
-    assert.is_nil(updated.due)
-  end)
-
-  it('removes category', function()
-    local s = pending.store()
-    local t = s:add({ description = 'Task one', category = 'Work' })
-    s:save()
-    pending.edit(tostring(t.id), '-cat')
-    local updated = s:get(t.id)
-    assert.is_nil(updated.category)
-  end)
-
-  it('sets recurrence', function()
-    local s = pending.store()
-    local t = s:add({ description = 'Task one' })
-    s:save()
-    pending.edit(tostring(t.id), 'rec:weekly')
-    local updated = s:get(t.id)
-    assert.are.equal('weekly', updated.recur)
-    assert.is_nil(updated.recur_mode)
-  end)
-
-  it('sets completion-based recurrence', function()
-    local s = pending.store()
-    local t = s:add({ description = 'Task one' })
-    s:save()
-    pending.edit(tostring(t.id), 'rec:!daily')
-    local updated = s:get(t.id)
-    assert.are.equal('daily', updated.recur)
-    assert.are.equal('completion', updated.recur_mode)
-  end)
-
-  it('removes recurrence', function()
-    local s = pending.store()
-    local t = s:add({ description = 'Task one', recur = 'weekly', recur_mode = 'scheduled' })
-    s:save()
-    pending.edit(tostring(t.id), '-rec')
-    local updated = s:get(t.id)
-    assert.is_nil(updated.recur)
-    assert.is_nil(updated.recur_mode)
-  end)
-
-  it('applies multiple operations at once', function()
-    local s = pending.store()
-    local t = s:add({ description = 'Task one' })
-    s:save()
-    pending.edit(tostring(t.id), 'due:today cat:Errands +!')
-    local updated = s:get(t.id)
-    assert.are.equal(os.date('%Y-%m-%d'), updated.due)
-    assert.are.equal('Errands', updated.category)
-    assert.are.equal(1, updated.priority)
-  end)
-
-  it('pushes to undo stack', function()
-    local s = pending.store()
-    local t = s:add({ description = 'Task one' })
-    s:save()
-    local stack_before = #s:undo_stack()
-    pending.edit(tostring(t.id), 'cat:Work')
-    assert.are.equal(stack_before + 1, #s:undo_stack())
-  end)
-
-  it('persists changes to disk', function()
-    local s = pending.store()
-    local t = s:add({ description = 'Task one' })
-    s:save()
-    pending.edit(tostring(t.id), 'cat:Work')
-    s:load()
-    local updated = s:get(t.id)
-    assert.are.equal('Work', updated.category)
-  end)
-
-  it('errors on unknown task ID', function()
-    local s = pending.store()
-    s:add({ description = 'Task one' })
-    s:save()
-    local messages = {}
-    local orig_notify = vim.notify
-    vim.notify = function(msg, level)
-      table.insert(messages, { msg = msg, level = level })
-    end
-    pending.edit('999', 'cat:Work')
-    vim.notify = orig_notify
-    assert.are.equal(1, #messages)
-    assert.truthy(messages[1].msg:find('No task with ID 999'))
-    assert.are.equal(vim.log.levels.ERROR, messages[1].level)
-  end)
-
-  it('errors on invalid date', function()
-    local s = pending.store()
-    local t = s:add({ description = 'Task one' })
-    s:save()
-    local messages = {}
-    local orig_notify = vim.notify
-    vim.notify = function(msg, level)
-      table.insert(messages, { msg = msg, level = level })
-    end
-    pending.edit(tostring(t.id), 'due:notadate')
-    vim.notify = orig_notify
-    assert.are.equal(1, #messages)
-    assert.truthy(messages[1].msg:find('Invalid date'))
-    assert.are.equal(vim.log.levels.ERROR, messages[1].level)
-  end)
-
-  it('errors on unknown operation token', function()
-    local s = pending.store()
-    local t = s:add({ description = 'Task one' })
-    s:save()
-    local messages = {}
-    local orig_notify = vim.notify
-    vim.notify = function(msg, level)
-      table.insert(messages, { msg = msg, level = level })
-    end
-    pending.edit(tostring(t.id), 'bogus')
-    vim.notify = orig_notify
-    assert.are.equal(1, #messages)
-    assert.truthy(messages[1].msg:find('Unknown operation'))
-    assert.are.equal(vim.log.levels.ERROR, messages[1].level)
-  end)
-
-  it('errors on invalid recurrence pattern', function()
-    local s = pending.store()
-    local t = s:add({ description = 'Task one' })
-    s:save()
-    local messages = {}
-    local orig_notify = vim.notify
-    vim.notify = function(msg, level)
-      table.insert(messages, { msg = msg, level = level })
-    end
-    pending.edit(tostring(t.id), 'rec:nope')
-    vim.notify = orig_notify
-    assert.are.equal(1, #messages)
-    assert.truthy(messages[1].msg:find('Invalid recurrence'))
-    assert.are.equal(vim.log.levels.ERROR, messages[1].level)
-  end)
-
-  it('errors when no operations given', function()
-    local s = pending.store()
-    local t = s:add({ description = 'Task one' })
-    s:save()
-    local messages = {}
-    local orig_notify = vim.notify
-    vim.notify = function(msg, level)
-      table.insert(messages, { msg = msg, level = level })
-    end
-    pending.edit(tostring(t.id), '')
-    vim.notify = orig_notify
-    assert.are.equal(1, #messages)
-    assert.truthy(messages[1].msg:find('Usage'))
-    assert.are.equal(vim.log.levels.ERROR, messages[1].level)
-  end)
-
-  it('errors when no id given', function()
-    local messages = {}
-    local orig_notify = vim.notify
-    vim.notify = function(msg, level)
-      table.insert(messages, { msg = msg, level = level })
-    end
-    pending.edit('', '')
-    vim.notify = orig_notify
-    assert.are.equal(1, #messages)
-    assert.truthy(messages[1].msg:find('Usage'))
-    assert.are.equal(vim.log.levels.ERROR, messages[1].level)
-  end)
-
-  it('errors on non-numeric id', function()
-    local messages = {}
-    local orig_notify = vim.notify
-    vim.notify = function(msg, level)
-      table.insert(messages, { msg = msg, level = level })
-    end
-    pending.edit('abc', 'cat:Work')
-    vim.notify = orig_notify
-    assert.are.equal(1, #messages)
-    assert.truthy(messages[1].msg:find('Invalid task ID'))
-    assert.are.equal(vim.log.levels.ERROR, messages[1].level)
-  end)
-
-  it('shows feedback message on success', function()
-    local s = pending.store()
-    local t = s:add({ description = 'Task one' })
-    s:save()
-    local messages = {}
-    local orig_notify = vim.notify
-    vim.notify = function(msg, level)
-      table.insert(messages, { msg = msg, level = level })
-    end
-    pending.edit(tostring(t.id), 'cat:Work')
-    vim.notify = orig_notify
-    assert.are.equal(1, #messages)
-    assert.truthy(messages[1].msg:find('Task #' .. t.id .. ' updated'))
-    assert.truthy(messages[1].msg:find('category set to Work'))
-  end)
-
-  it('respects custom date_syntax', function()
-    vim.g.pending = { data_path = tmpdir .. '/tasks.json', date_syntax = 'by' }
-    config.reset()
-    package.loaded['pending'] = nil
-    pending = require('pending')
-    local s = pending.store()
-    s:load()
-    local t = s:add({ description = 'Task one' })
-    s:save()
-    pending.edit(tostring(t.id), 'by:tomorrow')
-    local updated = s:get(t.id)
-    local today = os.date('*t') --[[@as osdate]]
-    local expected =
-      os.date('%Y-%m-%d', os.time({ year = today.year, month = today.month, day = today.day + 1 }))
-    assert.are.equal(expected, updated.due)
-  end)
-
-  it('respects custom recur_syntax', function()
-    vim.g.pending = { data_path = tmpdir .. '/tasks.json', recur_syntax = 'repeat' }
-    config.reset()
-    package.loaded['pending'] = nil
-    pending = require('pending')
-    local s = pending.store()
-    s:load()
-    local t = s:add({ description = 'Task one' })
-    s:save()
-    pending.edit(tostring(t.id), 'repeat:weekly')
-    local updated = s:get(t.id)
-    assert.are.equal('weekly', updated.recur)
-  end)
-
-  it('does not modify store on error', function()
-    local s = pending.store()
-    local t = s:add({ description = 'Task one', category = 'Original' })
-    s:save()
-    local orig_notify = vim.notify
-    vim.notify = function() end
-    pending.edit(tostring(t.id), 'due:notadate')
-    vim.notify = orig_notify
-    local updated = s:get(t.id)
-    assert.are.equal('Original', updated.category)
-    assert.is_nil(updated.due)
-  end)
-
-  it('sets due date with datetime format', function()
-    local s = pending.store()
-    local t = s:add({ description = 'Task one' })
-    s:save()
-    pending.edit(tostring(t.id), 'due:tomorrow@14:00')
-    local updated = s:get(t.id)
-    local today = os.date('*t') --[[@as osdate]]
-    local expected =
-      os.date('%Y-%m-%d', os.time({ year = today.year, month = today.month, day = today.day + 1 }))
-    assert.are.equal(expected .. 'T14:00', updated.due)
-  end)
-end)

spec/filter_spec.lua

@@ -1,292 +0,0 @@
-require('spec.helpers')
-
-local config = require('pending.config')
-local diff = require('pending.diff')
-
-describe('filter', function()
-  local tmpdir
-  local pending
-  local buffer
-
-  before_each(function()
-    tmpdir = vim.fn.tempname()
-    vim.fn.mkdir(tmpdir, 'p')
-    vim.g.pending = { data_path = tmpdir .. '/tasks.json' }
-    config.reset()
-    package.loaded['pending'] = nil
-    package.loaded['pending.buffer'] = nil
-    pending = require('pending')
-    buffer = require('pending.buffer')
-    buffer.set_filter({}, {})
-    pending.store():load()
-  end)
-
-  after_each(function()
-    vim.fn.delete(tmpdir, 'rf')
-    vim.g.pending = nil
-    config.reset()
-    package.loaded['pending'] = nil
-    package.loaded['pending.buffer'] = nil
-  end)
-
-  describe('filter predicates', function()
-    it('cat: hides tasks with non-matching category', function()
-      local s = pending.store()
-      s:add({ description = 'Work task', category = 'Work' })
-      s:add({ description = 'Home task', category = 'Home' })
-      s:save()
-      pending.filter('cat:Work')
-      local hidden = buffer.hidden_ids()
-      local tasks = s:active_tasks()
-      local work_task = nil
-      local home_task = nil
-      for _, t in ipairs(tasks) do
-        if t.category == 'Work' then
-          work_task = t
-        end
-        if t.category == 'Home' then
-          home_task = t
-        end
-      end
-      assert.is_not_nil(work_task)
-      assert.is_not_nil(home_task)
-      assert.is_nil(hidden[work_task.id])
-      assert.is_true(hidden[home_task.id])
-    end)
-
-    it('cat: hides tasks with no category (default category)', function()
-      local s = pending.store()
-      s:add({ description = 'Work task', category = 'Work' })
-      s:add({ description = 'Inbox task' })
-      s:save()
-      pending.filter('cat:Work')
-      local hidden = buffer.hidden_ids()
-      local tasks = s:active_tasks()
-      local inbox_task = nil
-      for _, t in ipairs(tasks) do
-        if t.category ~= 'Work' then
-          inbox_task = t
-        end
-      end
-      assert.is_not_nil(inbox_task)
-      assert.is_true(hidden[inbox_task.id])
-    end)
-
-    it('overdue hides non-overdue tasks', function()
-      local s = pending.store()
-      s:add({ description = 'Old task', due = '2020-01-01' })
-      s:add({ description = 'Future task', due = '2099-01-01' })
-      s:add({ description = 'No due task' })
-      s:save()
-      pending.filter('overdue')
-      local hidden = buffer.hidden_ids()
-      local tasks = s:active_tasks()
-      local overdue_task, future_task, nodue_task
-      for _, t in ipairs(tasks) do
-        if t.due == '2020-01-01' then
-          overdue_task = t
-        end
-        if t.due == '2099-01-01' then
-          future_task = t
-        end
-        if not t.due then
-          nodue_task = t
-        end
-      end
-      assert.is_nil(hidden[overdue_task.id])
-      assert.is_true(hidden[future_task.id])
-      assert.is_true(hidden[nodue_task.id])
-    end)
-
-    it('today hides non-today tasks', function()
-      local s = pending.store()
-      local today = os.date('%Y-%m-%d') --[[@as string]]
-      s:add({ description = 'Today task', due = today })
-      s:add({ description = 'Old task', due = '2020-01-01' })
-      s:add({ description = 'Future task', due = '2099-01-01' })
-      s:save()
-      pending.filter('today')
-      local hidden = buffer.hidden_ids()
-      local tasks = s:active_tasks()
-      local today_task, old_task, future_task
-      for _, t in ipairs(tasks) do
-        if t.due == today then
-          today_task = t
-        end
-        if t.due == '2020-01-01' then
-          old_task = t
-        end
-        if t.due == '2099-01-01' then
-          future_task = t
-        end
-      end
-      assert.is_nil(hidden[today_task.id])
-      assert.is_true(hidden[old_task.id])
-      assert.is_true(hidden[future_task.id])
-    end)
-
-    it('priority hides non-priority tasks', function()
-      local s = pending.store()
-      s:add({ description = 'Important', priority = 1 })
-      s:add({ description = 'Normal' })
-      s:save()
-      pending.filter('priority')
-      local hidden = buffer.hidden_ids()
-      local tasks = s:active_tasks()
-      local important_task, normal_task
-      for _, t in ipairs(tasks) do
-        if t.priority and t.priority > 0 then
-          important_task = t
-        end
-        if not t.priority or t.priority == 0 then
-          normal_task = t
-        end
-      end
-      assert.is_nil(hidden[important_task.id])
-      assert.is_true(hidden[normal_task.id])
-    end)
-
-    it('multi-predicate AND: cat:Work + overdue', function()
-      local s = pending.store()
-      s:add({ description = 'Work overdue', category = 'Work', due = '2020-01-01' })
-      s:add({ description = 'Work future', category = 'Work', due = '2099-01-01' })
-      s:add({ description = 'Home overdue', category = 'Home', due = '2020-01-01' })
-      s:save()
-      pending.filter('cat:Work overdue')
-      local hidden = buffer.hidden_ids()
-      local tasks = s:active_tasks()
-      local work_overdue, work_future, home_overdue
-      for _, t in ipairs(tasks) do
-        if t.description == 'Work overdue' then
-          work_overdue = t
-        end
-        if t.description == 'Work future' then
-          work_future = t
-        end
-        if t.description == 'Home overdue' then
-          home_overdue = t
-        end
-      end
-      assert.is_nil(hidden[work_overdue.id])
-      assert.is_true(hidden[work_future.id])
-      assert.is_true(hidden[home_overdue.id])
-    end)
-
-    it('filter clear removes all predicates and hidden ids', function()
-      local s = pending.store()
-      s:add({ description = 'Work task', category = 'Work' })
-      s:add({ description = 'Home task', category = 'Home' })
-      s:save()
-      pending.filter('cat:Work')
-      assert.are.equal(1, #buffer.filter_predicates())
-      pending.filter('clear')
-      assert.are.equal(0, #buffer.filter_predicates())
-      assert.are.same({}, buffer.hidden_ids())
-    end)
-
-    it('filter empty string clears filter', function()
-      local s = pending.store()
-      s:add({ description = 'Work task', category = 'Work' })
-      s:save()
-      pending.filter('cat:Work')
-      assert.are.equal(1, #buffer.filter_predicates())
-      pending.filter('')
-      assert.are.equal(0, #buffer.filter_predicates())
-    end)
-
-    it('filter predicates persist across set_filter calls', function()
-      local s = pending.store()
-      s:add({ description = 'Work task', category = 'Work' })
-      s:add({ description = 'Home task', category = 'Home' })
-      s:save()
-      pending.filter('cat:Work')
-      local preds = buffer.filter_predicates()
-      assert.are.equal(1, #preds)
-      assert.are.equal('cat:Work', preds[1])
-      local hidden = buffer.hidden_ids()
-      local tasks = s:active_tasks()
-      local home_task
-      for _, t in ipairs(tasks) do
-        if t.category == 'Home' then
-          home_task = t
-        end
-      end
-      assert.is_true(hidden[home_task.id])
-    end)
-  end)
-
-  describe('diff.apply with hidden_ids', function()
-    it('does not mark hidden tasks as deleted', function()
-      local s = pending.store()
-      s:add({ description = 'Visible task' })
-      s:add({ description = 'Hidden task' })
-      s:save()
-      local tasks = s:active_tasks()
-      local hidden_task
-      for _, t in ipairs(tasks) do
-        if t.description == 'Hidden task' then
-          hidden_task = t
-        end
-      end
-      local hidden_ids = { [hidden_task.id] = true }
-      local lines = {
-        '/1/- [ ] Visible task',
-      }
-      diff.apply(lines, s, hidden_ids)
-      s:load()
-      local hidden = s:get(hidden_task.id)
-      assert.are.equal('pending', hidden.status)
-    end)
-
-    it('marks tasks deleted when not hidden and not in buffer', function()
-      local s = pending.store()
-      s:add({ description = 'Keep task' })
-      s:add({ description = 'Delete task' })
-      s:save()
-      local tasks = s:active_tasks()
-      local keep_task, delete_task
-      for _, t in ipairs(tasks) do
-        if t.description == 'Keep task' then
-          keep_task = t
-        end
-        if t.description == 'Delete task' then
-          delete_task = t
-        end
-      end
-      local lines = {
-        '/' .. keep_task.id .. '/- [ ] Keep task',
-      }
-      diff.apply(lines, s, {})
-      s:load()
-      local deleted = s:get(delete_task.id)
-      assert.are.equal('deleted', deleted.status)
-    end)
-
-    it('strips FILTER: line before parsing', function()
-      local s = pending.store()
-      s:add({ description = 'My task' })
-      s:save()
-      local tasks = s:active_tasks()
-      local task = tasks[1]
-      local lines = {
-        'FILTER: cat:Work',
-        '/' .. task.id .. '/- [ ] My task',
-      }
-      diff.apply(lines, s, {})
-      s:load()
-      local t = s:get(task.id)
-      assert.are.equal('pending', t.status)
-    end)
-
-    it('parse_buffer skips FILTER: header line', function()
-      local lines = {
-        'FILTER: overdue',
-        '/1/- [ ] A task',
-      }
-      local result = diff.parse_buffer(lines)
-      assert.are.equal(1, #result)
-      assert.are.equal('task', result[1].type)
-      assert.are.equal('A task', result[1].description)
-    end)
-  end)
-end)

spec/gtasks_spec.lua

@@ -1,368 +0,0 @@
-require('spec.helpers')
-
-local gtasks = require('pending.sync.gtasks')
-
-describe('gtasks field conversion', function()
-  describe('due date helpers', function()
-    it('converts date-only to RFC 3339', function()
-      assert.equals('2026-03-15T00:00:00.000Z', gtasks._due_to_rfc3339('2026-03-15'))
-    end)
-
-    it('converts datetime to RFC 3339 (strips time)', function()
-      assert.equals('2026-03-15T00:00:00.000Z', gtasks._due_to_rfc3339('2026-03-15T14:30'))
-    end)
-
-    it('strips RFC 3339 to date-only', function()
-      assert.equals('2026-03-15', gtasks._rfc3339_to_date('2026-03-15T00:00:00.000Z'))
-    end)
-  end)
-
-  describe('build_notes', function()
-    it('returns nil when no priority or recur', function()
-      assert.is_nil(gtasks._build_notes({ priority = 0, recur = nil }))
-    end)
-
-    it('encodes priority', function()
-      assert.equals('pri:1', gtasks._build_notes({ priority = 1, recur = nil }))
-    end)
-
-    it('encodes recur', function()
-      assert.equals('rec:weekly', gtasks._build_notes({ priority = 0, recur = 'weekly' }))
-    end)
-
-    it('encodes completion-mode recur with ! prefix', function()
-      assert.equals(
-        'rec:!daily',
-        gtasks._build_notes({ priority = 0, recur = 'daily', recur_mode = 'completion' })
-      )
-    end)
-
-    it('encodes both priority and recur', function()
-      assert.equals('pri:1 rec:weekly', gtasks._build_notes({ priority = 1, recur = 'weekly' }))
-    end)
-  end)
-
-  describe('parse_notes', function()
-    it('returns zeros/nils for nil input', function()
-      local pri, rec, mode = gtasks._parse_notes(nil)
-      assert.equals(0, pri)
-      assert.is_nil(rec)
-      assert.is_nil(mode)
-    end)
-
-    it('parses priority', function()
-      local pri = gtasks._parse_notes('pri:1')
-      assert.equals(1, pri)
-    end)
-
-    it('parses recur', function()
-      local _, rec = gtasks._parse_notes('rec:weekly')
-      assert.equals('weekly', rec)
-    end)
-
-    it('parses completion-mode recur', function()
-      local _, rec, mode = gtasks._parse_notes('rec:!daily')
-      assert.equals('daily', rec)
-      assert.equals('completion', mode)
-    end)
-
-    it('parses both priority and recur', function()
-      local pri, rec = gtasks._parse_notes('pri:1 rec:monthly')
-      assert.equals(1, pri)
-      assert.equals('monthly', rec)
-    end)
-
-    it('round-trips through build_notes', function()
-      local task = { priority = 1, recur = 'weekly', recur_mode = nil }
-      local notes = gtasks._build_notes(task)
-      local pri, rec = gtasks._parse_notes(notes)
-      assert.equals(1, pri)
-      assert.equals('weekly', rec)
-    end)
-  end)
-
-  describe('task_to_gtask', function()
-    it('maps description to title', function()
-      local body = gtasks._task_to_gtask({
-        description = 'Buy milk',
-        status = 'pending',
-        priority = 0,
-      })
-      assert.equals('Buy milk', body.title)
-    end)
-
-    it('maps pending status to needsAction', function()
-      local body = gtasks._task_to_gtask({ description = 'x', status = 'pending', priority = 0 })
-      assert.equals('needsAction', body.status)
-    end)
-
-    it('maps done status to completed', function()
-      local body = gtasks._task_to_gtask({ description = 'x', status = 'done', priority = 0 })
-      assert.equals('completed', body.status)
-    end)
-
-    it('converts due date to RFC 3339', function()
-      local body = gtasks._task_to_gtask({
-        description = 'x',
-        status = 'pending',
-        priority = 0,
-        due = '2026-03-15',
-      })
-      assert.equals('2026-03-15T00:00:00.000Z', body.due)
-    end)
-
-    it('omits due when nil', function()
-      local body = gtasks._task_to_gtask({ description = 'x', status = 'pending', priority = 0 })
-      assert.is_nil(body.due)
-    end)
-
-    it('includes notes when priority is set', function()
-      local body = gtasks._task_to_gtask({ description = 'x', status = 'pending', priority = 1 })
-      assert.equals('pri:1', body.notes)
-    end)
-
-    it('omits notes when no extra fields', function()
-      local body = gtasks._task_to_gtask({ description = 'x', status = 'pending', priority = 0 })
-      assert.is_nil(body.notes)
-    end)
-  end)
-
-  describe('gtask_to_fields', function()
-    it('maps title to description', function()
-      local fields = gtasks._gtask_to_fields({ title = 'Buy milk', status = 'needsAction' }, 'Work')
-      assert.equals('Buy milk', fields.description)
-    end)
-
-    it('maps category from list name', function()
-      local fields = gtasks._gtask_to_fields({ title = 'x', status = 'needsAction' }, 'Personal')
-      assert.equals('Personal', fields.category)
-    end)
-
-    it('maps needsAction to pending', function()
-      local fields = gtasks._gtask_to_fields({ title = 'x', status = 'needsAction' }, 'Work')
-      assert.equals('pending', fields.status)
-    end)
-
-    it('maps completed to done', function()
-      local fields = gtasks._gtask_to_fields({ title = 'x', status = 'completed' }, 'Work')
-      assert.equals('done', fields.status)
-    end)
-
-    it('strips due date to YYYY-MM-DD', function()
-      local fields = gtasks._gtask_to_fields({
-        title = 'x',
-        status = 'needsAction',
-        due = '2026-03-15T00:00:00.000Z',
-      }, 'Work')
-      assert.equals('2026-03-15', fields.due)
-    end)
-
-    it('parses priority from notes', function()
-      local fields = gtasks._gtask_to_fields({
-        title = 'x',
-        status = 'needsAction',
-        notes = 'pri:1',
-      }, 'Work')
-      assert.equals(1, fields.priority)
-    end)
-
-    it('parses recur from notes', function()
-      local fields = gtasks._gtask_to_fields({
-        title = 'x',
-        status = 'needsAction',
-        notes = 'rec:weekly',
-      }, 'Work')
-      assert.equals('weekly', fields.recur)
-    end)
-  end)
-end)
-
-describe('gtasks push_pass _gtasks_synced_at', function()
-  local helpers = require('spec.helpers')
-  local store_mod = require('pending.store')
-  local oauth = require('pending.sync.oauth')
-  local s
-  local orig_curl
-
-  before_each(function()
-    local dir = helpers.tmpdir()
-    s = store_mod.new(dir .. '/pending.json')
-    s:load()
-    orig_curl = oauth.curl_request
-  end)
-
-  after_each(function()
-    oauth.curl_request = orig_curl
-  end)
-
-  it('sets _gtasks_synced_at after push create', function()
-    local task =
-      s:add({ description = 'New task', status = 'pending', category = 'Work', priority = 0 })
-
-    oauth.curl_request = function(method, url, _headers, _body)
-      if method == 'POST' and url:find('/tasks$') then
-        return { id = 'gtask-new-1' }, nil
-      end
-      return {}, nil
-    end
-
-    local now_ts = '2026-03-05T10:00:00Z'
-    local tasklists = { Work = 'list-1' }
-    local by_id = {}
-    gtasks._push_pass('fake-token', tasklists, s, now_ts, by_id)
-
-    assert.is_not_nil(task._extra)
-    assert.equals('2026-03-05T10:00:00Z', task._extra['_gtasks_synced_at'])
-  end)
-
-  it('skips update when modified <= _gtasks_synced_at', function()
-    local task =
-      s:add({ description = 'Existing task', status = 'pending', category = 'Work', priority = 0 })
-    task._extra = {
-      _gtasks_task_id = 'remote-1',
-      _gtasks_list_id = 'list-1',
-      _gtasks_synced_at = '2026-03-05T10:00:00Z',
-    }
-    task.modified = '2026-03-05T09:00:00Z'
-
-    local patch_called = false
-    oauth.curl_request = function(method, _url, _headers, _body)
-      if method == 'PATCH' then
-        patch_called = true
-      end
-      return {}, nil
-    end
-
-    local now_ts = '2026-03-05T11:00:00Z'
-    local tasklists = { Work = 'list-1' }
-    local by_id = { ['remote-1'] = task }
-    gtasks._push_pass('fake-token', tasklists, s, now_ts, by_id)
-
-    assert.is_false(patch_called)
-  end)
-
-  it('pushes update when modified > _gtasks_synced_at', function()
-    local task =
-      s:add({ description = 'Changed task', status = 'pending', category = 'Work', priority = 0 })
-    task._extra = {
-      _gtasks_task_id = 'remote-2',
-      _gtasks_list_id = 'list-1',
-      _gtasks_synced_at = '2026-03-05T08:00:00Z',
-    }
-    task.modified = '2026-03-05T09:00:00Z'
-
-    local patch_called = false
-    oauth.curl_request = function(method, _url, _headers, _body)
-      if method == 'PATCH' then
-        patch_called = true
-      end
-      return {}, nil
-    end
-
-    local now_ts = '2026-03-05T11:00:00Z'
-    local tasklists = { Work = 'list-1' }
-    local by_id = { ['remote-2'] = task }
-    gtasks._push_pass('fake-token', tasklists, s, now_ts, by_id)
-
-    assert.is_true(patch_called)
-  end)
-
-  it('pushes update when no _gtasks_synced_at (backwards compat)', function()
-    local task =
-      s:add({ description = 'Old task', status = 'pending', category = 'Work', priority = 0 })
-    task._extra = {
-      _gtasks_task_id = 'remote-3',
-      _gtasks_list_id = 'list-1',
-    }
-    task.modified = '2026-01-01T00:00:00Z'
-
-    local patch_called = false
-    oauth.curl_request = function(method, _url, _headers, _body)
-      if method == 'PATCH' then
-        patch_called = true
-      end
-      return {}, nil
-    end
-
-    local now_ts = '2026-03-05T11:00:00Z'
-    local tasklists = { Work = 'list-1' }
-    local by_id = { ['remote-3'] = task }
-    gtasks._push_pass('fake-token', tasklists, s, now_ts, by_id)
-
-    assert.is_true(patch_called)
-  end)
-end)
-
-describe('gtasks detect_remote_deletions', function()
-  local helpers = require('spec.helpers')
-  local store_mod = require('pending.store')
-  local s
-
-  before_each(function()
-    local dir = helpers.tmpdir()
-    s = store_mod.new(dir .. '/pending.json')
-    s:load()
-  end)
-
-  it('clears remote IDs when list was fetched but task ID is absent', function()
-    local task =
-      s:add({ description = 'Gone remote', status = 'pending', category = 'Work', priority = 0 })
-    task._extra = {
-      _gtasks_task_id = 'old-remote-id',
-      _gtasks_list_id = 'list-1',
-      _gtasks_synced_at = '2026-01-01T00:00:00Z',
-    }
-
-    local seen = {}
-    local fetched = { ['list-1'] = true }
-    local now_ts = '2026-03-05T10:00:00Z'
-
-    local unlinked = gtasks._detect_remote_deletions(s, seen, fetched, now_ts)
-
-    assert.equals(1, unlinked)
-    assert.is_nil(task._extra)
-    assert.equals('2026-03-05T10:00:00Z', task.modified)
-  end)
-
-  it('leaves task untouched when its list fetch failed', function()
-    local task = s:add({
-      description = 'Unknown list task',
-      status = 'pending',
-      category = 'Work',
-      priority = 0,
-    })
-    task._extra = {
-      _gtasks_task_id = 'remote-id',
-      _gtasks_list_id = 'list-unfetched',
-    }
-
-    local seen = {}
-    local fetched = {}
-    local now_ts = '2026-03-05T10:00:00Z'
-
-    local unlinked = gtasks._detect_remote_deletions(s, seen, fetched, now_ts)
-
-    assert.equals(0, unlinked)
-    assert.is_not_nil(task._extra)
-    assert.equals('remote-id', task._extra['_gtasks_task_id'])
-  end)
-
-  it('skips tasks with status == deleted', function()
-    local task =
-      s:add({ description = 'Deleted task', status = 'deleted', category = 'Work', priority = 0 })
-    task._extra = {
-      _gtasks_task_id = 'remote-del',
-      _gtasks_list_id = 'list-1',
-    }
-
-    local seen = {}
-    local fetched = { ['list-1'] = true }
-    local now_ts = '2026-03-05T10:00:00Z'
-
-    local unlinked = gtasks._detect_remote_deletions(s, seen, fetched, now_ts)
-
-    assert.equals(0, unlinked)
-    assert.is_not_nil(task._extra)
-    assert.equals('remote-del', task._extra['_gtasks_task_id'])
-  end)
-end)

spec/icons_spec.lua

@@ -1,56 +0,0 @@
-require('spec.helpers')
-
-local config = require('pending.config')
-
-describe('icons', function()
-  before_each(function()
-    vim.g.pending = nil
-    config.reset()
-  end)
-
-  after_each(function()
-    vim.g.pending = nil
-    config.reset()
-  end)
-
-  it('has default icon values', function()
-    local icons = config.get().icons
-    assert.equals(' ', icons.pending)
-    assert.equals('x', icons.done)
-    assert.equals('!', icons.priority)
-    assert.equals('.', icons.due)
-    assert.equals('~', icons.recur)
-    assert.equals('#', icons.category)
-  end)
-
-  it('allows overriding individual icons', function()
-    vim.g.pending = { icons = { pending = '*', done = '+' } }
-    config.reset()
-    local icons = config.get().icons
-    assert.equals('*', icons.pending)
-    assert.equals('+', icons.done)
-    assert.equals('!', icons.priority)
-    assert.equals('#', icons.category)
-  end)
-
-  it('allows overriding all icons', function()
-    vim.g.pending = {
-      icons = {
-        pending = '-',
-        done = '+',
-        priority = '*',
-        due = '@',
-        recur = '^',
-        category = '&',
-      },
-    }
-    config.reset()
-    local icons = config.get().icons
-    assert.equals('-', icons.pending)
-    assert.equals('+', icons.done)
-    assert.equals('*', icons.priority)
-    assert.equals('@', icons.due)
-    assert.equals('^', icons.recur)
-    assert.equals('&', icons.category)
-  end)
-end)

spec/oauth_spec.lua

@@ -1,230 +0,0 @@
-require('spec.helpers')
-
-local config = require('pending.config')
-local oauth = require('pending.sync.oauth')
-
-describe('oauth', function()
-  local tmpdir
-
-  before_each(function()
-    tmpdir = vim.fn.tempname()
-    vim.fn.mkdir(tmpdir, 'p')
-    vim.g.pending = { data_path = tmpdir .. '/tasks.json' }
-    config.reset()
-  end)
-
-  after_each(function()
-    vim.fn.delete(tmpdir, 'rf')
-    vim.g.pending = nil
-    config.reset()
-  end)
-
-  describe('url_encode', function()
-    it('leaves alphanumerics unchanged', function()
-      assert.equals('hello123', oauth.url_encode('hello123'))
-    end)
-
-    it('encodes spaces', function()
-      assert.equals('hello%20world', oauth.url_encode('hello world'))
-    end)
-
-    it('encodes special characters', function()
-      assert.equals('a%3Db%26c', oauth.url_encode('a=b&c'))
-    end)
-
-    it('preserves hyphens, dots, underscores, tildes', function()
-      assert.equals('a-b.c_d~e', oauth.url_encode('a-b.c_d~e'))
-    end)
-  end)
-
-  describe('load_json_file', function()
-    it('returns nil for missing file', function()
-      assert.is_nil(oauth.load_json_file(tmpdir .. '/nonexistent.json'))
-    end)
-
-    it('returns nil for empty file', function()
-      local path = tmpdir .. '/empty.json'
-      local f = io.open(path, 'w')
-      f:write('')
-      f:close()
-      assert.is_nil(oauth.load_json_file(path))
-    end)
-
-    it('returns nil for invalid JSON', function()
-      local path = tmpdir .. '/bad.json'
-      local f = io.open(path, 'w')
-      f:write('not json')
-      f:close()
-      assert.is_nil(oauth.load_json_file(path))
-    end)
-
-    it('parses valid JSON', function()
-      local path = tmpdir .. '/good.json'
-      local f = io.open(path, 'w')
-      f:write('{"key":"value"}')
-      f:close()
-      local data = oauth.load_json_file(path)
-      assert.equals('value', data.key)
-    end)
-  end)
-
-  describe('save_json_file', function()
-    it('creates parent directories', function()
-      local path = tmpdir .. '/sub/dir/file.json'
-      local ok = oauth.save_json_file(path, { test = true })
-      assert.is_true(ok)
-      local data = oauth.load_json_file(path)
-      assert.is_true(data.test)
-    end)
-
-    it('sets restrictive permissions', function()
-      local path = tmpdir .. '/secret.json'
-      oauth.save_json_file(path, { x = 1 })
-      local perms = vim.fn.getfperm(path)
-      assert.equals('rw-------', perms)
-    end)
-  end)
-
-  describe('resolve_credentials', function()
-    it('uses config fields when set', function()
-      config.reset()
-      vim.g.pending = {
-        data_path = tmpdir .. '/tasks.json',
-        sync = {
-          gtasks = {
-            client_id = 'config-id',
-            client_secret = 'config-secret',
-          },
-        },
-      }
-      local c = oauth.new({ name = 'gtasks', scope = 'x', port = 0, config_key = 'gtasks' })
-      local creds = c:resolve_credentials()
-      assert.equals('config-id', creds.client_id)
-      assert.equals('config-secret', creds.client_secret)
-    end)
-
-    it('uses credentials file when config fields absent', function()
-      local cred_path = tmpdir .. '/creds.json'
-      oauth.save_json_file(cred_path, {
-        client_id = 'file-id',
-        client_secret = 'file-secret',
-      })
-      config.reset()
-      vim.g.pending = {
-        data_path = tmpdir .. '/tasks.json',
-        sync = { gtasks = { credentials_path = cred_path } },
-      }
-      local c = oauth.new({ name = 'gtasks', scope = 'x', port = 0, config_key = 'gtasks' })
-      local creds = c:resolve_credentials()
-      assert.equals('file-id', creds.client_id)
-      assert.equals('file-secret', creds.client_secret)
-    end)
-
-    it('unwraps installed wrapper format', function()
-      local cred_path = tmpdir .. '/wrapped.json'
-      oauth.save_json_file(cred_path, {
-        installed = {
-          client_id = 'wrapped-id',
-          client_secret = 'wrapped-secret',
-        },
-      })
-      config.reset()
-      vim.g.pending = {
-        data_path = tmpdir .. '/tasks.json',
-        sync = { gcal = { credentials_path = cred_path } },
-      }
-      local c = oauth.new({ name = 'gcal', scope = 'x', port = 0, config_key = 'gcal' })
-      local creds = c:resolve_credentials()
-      assert.equals('wrapped-id', creds.client_id)
-      assert.equals('wrapped-secret', creds.client_secret)
-    end)
-
-    it('falls back to bundled credentials', function()
-      config.reset()
-      vim.g.pending = { data_path = tmpdir .. '/tasks.json' }
-      local c = oauth.new({ name = 'gtasks', scope = 'x', port = 0, config_key = 'gtasks' })
-      local creds = c:resolve_credentials()
-      assert.equals(oauth._BUNDLED_CLIENT_ID, creds.client_id)
-      assert.equals(oauth._BUNDLED_CLIENT_SECRET, creds.client_secret)
-    end)
-
-    it('prefers config fields over credentials file', function()
-      local cred_path = tmpdir .. '/creds2.json'
-      oauth.save_json_file(cred_path, {
-        client_id = 'file-id',
-        client_secret = 'file-secret',
-      })
-      config.reset()
-      vim.g.pending = {
-        data_path = tmpdir .. '/tasks.json',
-        sync = {
-          gtasks = {
-            credentials_path = cred_path,
-            client_id = 'config-id',
-            client_secret = 'config-secret',
-          },
-        },
-      }
-      local c = oauth.new({ name = 'gtasks', scope = 'x', port = 0, config_key = 'gtasks' })
-      local creds = c:resolve_credentials()
-      assert.equals('config-id', creds.client_id)
-      assert.equals('config-secret', creds.client_secret)
-    end)
-  end)
-
-  describe('token_path', function()
-    it('includes backend name', function()
-      local c = oauth.new({ name = 'gtasks', scope = 'x', port = 0, config_key = 'gtasks' })
-      assert.truthy(c:token_path():match('gtasks_tokens%.json$'))
-    end)
-
-    it('differs between backends', function()
-      local g = oauth.new({ name = 'gcal', scope = 'x', port = 0, config_key = 'gcal' })
-      local t = oauth.new({ name = 'gtasks', scope = 'x', port = 0, config_key = 'gtasks' })
-      assert.not_equals(g:token_path(), t:token_path())
-    end)
-  end)
-
-  describe('load_tokens / save_tokens', function()
-    it('round-trips tokens', function()
-      local c = oauth.new({ name = 'test', scope = 'x', port = 0, config_key = 'gtasks' })
-      local path = c:token_path()
-      local dir = vim.fn.fnamemodify(path, ':h')
-      vim.fn.mkdir(dir, 'p')
-      local tokens = {
-        access_token = 'at',
-        refresh_token = 'rt',
-        expires_in = 3600,
-        obtained_at = 1000,
-      }
-      c:save_tokens(tokens)
-      local loaded = c:load_tokens()
-      assert.equals('at', loaded.access_token)
-      assert.equals('rt', loaded.refresh_token)
-      vim.fn.delete(dir, 'rf')
-    end)
-  end)
-
-  describe('auth_headers', function()
-    it('includes bearer token', function()
-      local headers = oauth.auth_headers('mytoken')
-      assert.equals('Authorization: Bearer mytoken', headers[1])
-      assert.equals('Content-Type: application/json', headers[2])
-    end)
-  end)
-
-  describe('new', function()
-    it('creates client with correct fields', function()
-      local c = oauth.new({
-        name = 'test',
-        scope = 'https://example.com',
-        port = 12345,
-        config_key = 'test',
-      })
-      assert.equals('test', c.name)
-      assert.equals('https://example.com', c.scope)
-      assert.equals(12345, c.port)
-      assert.equals('test', c.config_key)
-    end)
-  end)
-end)

spec/parse_spec.lua

@@ -154,240 +154,6 @@ describe('parse', function()
       local result = parse.resolve_date('')
       assert.is_nil(result)
     end)
-
-    it("returns yesterday's date for 'yesterday'", function()
-      local expected = os.date('%Y-%m-%d', os.time() - 86400)
-      local result = parse.resolve_date('yesterday')
-      assert.are.equal(expected, result)
-    end)
-
-    it("returns today's date for 'eod'", function()
-      local result = parse.resolve_date('eod')
-      assert.are.equal(os.date('%Y-%m-%d'), result)
-    end)
-
-    it('returns Monday of current week for sow', function()
-      local result = parse.resolve_date('sow')
-      assert.is_not_nil(result)
-      local y, m, d = result:match('^(%d+)-(%d+)-(%d+)$')
-      local t = os.time({ year = tonumber(y), month = tonumber(m), day = tonumber(d) })
-      local wday = os.date('*t', t).wday
-      assert.are.equal(2, wday)
-    end)
-
-    it('returns Sunday of current week for eow', function()
-      local result = parse.resolve_date('eow')
-      assert.is_not_nil(result)
-      local y, m, d = result:match('^(%d+)-(%d+)-(%d+)$')
-      local t = os.time({ year = tonumber(y), month = tonumber(m), day = tonumber(d) })
-      local wday = os.date('*t', t).wday
-      assert.are.equal(1, wday)
-    end)
-
-    it('returns first day of current month for som', function()
-      local today = os.date('*t') --[[@as osdate]]
-      local expected = string.format('%04d-%02d-01', today.year, today.month)
-      local result = parse.resolve_date('som')
-      assert.are.equal(expected, result)
-    end)
-
-    it('returns last day of current month for eom', function()
-      local today = os.date('*t') --[[@as osdate]]
-      local expected =
-        os.date('%Y-%m-%d', os.time({ year = today.year, month = today.month + 1, day = 0 }))
-      local result = parse.resolve_date('eom')
-      assert.are.equal(expected, result)
-    end)
-
-    it('returns first day of current quarter for soq', function()
-      local today = os.date('*t') --[[@as osdate]]
-      local q = math.ceil(today.month / 3)
-      local first_month = (q - 1) * 3 + 1
-      local expected = string.format('%04d-%02d-01', today.year, first_month)
-      local result = parse.resolve_date('soq')
-      assert.are.equal(expected, result)
-    end)
-
-    it('returns last day of current quarter for eoq', function()
-      local today = os.date('*t') --[[@as osdate]]
-      local q = math.ceil(today.month / 3)
-      local last_month = q * 3
-      local expected =
-        os.date('%Y-%m-%d', os.time({ year = today.year, month = last_month + 1, day = 0 }))
-      local result = parse.resolve_date('eoq')
-      assert.are.equal(expected, result)
-    end)
-
-    it('returns Jan 1 of current year for soy', function()
-      local today = os.date('*t') --[[@as osdate]]
-      local expected = string.format('%04d-01-01', today.year)
-      local result = parse.resolve_date('soy')
-      assert.are.equal(expected, result)
-    end)
-
-    it('returns Dec 31 of current year for eoy', function()
-      local today = os.date('*t') --[[@as osdate]]
-      local expected = string.format('%04d-12-31', today.year)
-      local result = parse.resolve_date('eoy')
-      assert.are.equal(expected, result)
-    end)
-
-    it('resolves +2w to 14 days from today', function()
-      local today = os.date('*t') --[[@as osdate]]
-      local expected = os.date(
-        '%Y-%m-%d',
-        os.time({ year = today.year, month = today.month, day = today.day + 14 })
-      )
-      local result = parse.resolve_date('+2w')
-      assert.are.equal(expected, result)
-    end)
-
-    it('resolves +3m to 3 months from today', function()
-      local today = os.date('*t') --[[@as osdate]]
-      local expected = os.date(
-        '%Y-%m-%d',
-        os.time({ year = today.year, month = today.month + 3, day = today.day })
-      )
-      local result = parse.resolve_date('+3m')
-      assert.are.equal(expected, result)
-    end)
-
-    it('resolves -2d to 2 days ago', function()
-      local today = os.date('*t') --[[@as osdate]]
-      local expected = os.date(
-        '%Y-%m-%d',
-        os.time({ year = today.year, month = today.month, day = today.day - 2 })
-      )
-      local result = parse.resolve_date('-2d')
-      assert.are.equal(expected, result)
-    end)
-
-    it('resolves -1w to 7 days ago', function()
-      local today = os.date('*t') --[[@as osdate]]
-      local expected = os.date(
-        '%Y-%m-%d',
-        os.time({ year = today.year, month = today.month, day = today.day - 7 })
-      )
-      local result = parse.resolve_date('-1w')
-      assert.are.equal(expected, result)
-    end)
-
-    it("resolves 'later' to someday_date", function()
-      local result = parse.resolve_date('later')
-      assert.are.equal('9999-12-30', result)
-    end)
-
-    it("resolves 'someday' to someday_date", function()
-      local result = parse.resolve_date('someday')
-      assert.are.equal('9999-12-30', result)
-    end)
-
-    it('resolves 15th to next 15th of month', function()
-      local result = parse.resolve_date('15th')
-      assert.is_not_nil(result)
-      local _, _, d = result:match('^(%d+)-(%d+)-(%d+)$')
-      assert.are.equal('15', d)
-    end)
-
-    it('resolves 1st to next 1st of month', function()
-      local result = parse.resolve_date('1st')
-      assert.is_not_nil(result)
-      local _, _, d = result:match('^(%d+)-(%d+)-(%d+)$')
-      assert.are.equal('01', d)
-    end)
-
-    it('resolves jan to next January 1st', function()
-      local today = os.date('*t') --[[@as osdate]]
-      local result = parse.resolve_date('jan')
-      assert.is_not_nil(result)
-      local y, m, d = result:match('^(%d+)-(%d+)-(%d+)$')
-      assert.are.equal('01', m)
-      assert.are.equal('01', d)
-      if today.month >= 1 then
-        assert.are.equal(tostring(today.year + 1), y)
-      end
-    end)
-
-    it('resolves dec to next December 1st', function()
-      local today = os.date('*t') --[[@as osdate]]
-      local result = parse.resolve_date('dec')
-      assert.is_not_nil(result)
-      local y, m, d = result:match('^(%d+)-(%d+)-(%d+)$')
-      assert.are.equal('12', m)
-      assert.are.equal('01', d)
-      if today.month >= 12 then
-        assert.are.equal(tostring(today.year + 1), y)
-      else
-        assert.are.equal(tostring(today.year), y)
-      end
-    end)
-  end)
-
-  describe('resolve_date with time suffix', function()
-    local today = os.date('*t') --[[@as osdate]]
-    local tomorrow_str =
-      os.date('%Y-%m-%d', os.time({ year = today.year, month = today.month, day = today.day + 1 })) --[[@as string]]
-
-    it('resolves bare hour to T09:00', function()
-      local result = parse.resolve_date('tomorrow@9')
-      assert.are.equal(tomorrow_str .. 'T09:00', result)
-    end)
-
-    it('resolves bare military hour to T14:00', function()
-      local result = parse.resolve_date('tomorrow@14')
-      assert.are.equal(tomorrow_str .. 'T14:00', result)
-    end)
-
-    it('resolves H:MM to T09:30', function()
-      local result = parse.resolve_date('tomorrow@9:30')
-      assert.are.equal(tomorrow_str .. 'T09:30', result)
-    end)
-
-    it('resolves HH:MM (existing format) to T09:30', function()
-      local result = parse.resolve_date('tomorrow@09:30')
-      assert.are.equal(tomorrow_str .. 'T09:30', result)
-    end)
-
-    it('resolves 2pm to T14:00', function()
-      local result = parse.resolve_date('tomorrow@2pm')
-      assert.are.equal(tomorrow_str .. 'T14:00', result)
-    end)
-
-    it('resolves 9am to T09:00', function()
-      local result = parse.resolve_date('tomorrow@9am')
-      assert.are.equal(tomorrow_str .. 'T09:00', result)
-    end)
-
-    it('resolves 9:30pm to T21:30', function()
-      local result = parse.resolve_date('tomorrow@9:30pm')
-      assert.are.equal(tomorrow_str .. 'T21:30', result)
-    end)
-
-    it('resolves 12am to T00:00', function()
-      local result = parse.resolve_date('tomorrow@12am')
-      assert.are.equal(tomorrow_str .. 'T00:00', result)
-    end)
-
-    it('resolves 12pm to T12:00', function()
-      local result = parse.resolve_date('tomorrow@12pm')
-      assert.are.equal(tomorrow_str .. 'T12:00', result)
-    end)
-
-    it('rejects hour 24', function()
-      assert.is_nil(parse.resolve_date('tomorrow@24'))
-    end)
-
-    it('rejects 13am', function()
-      assert.is_nil(parse.resolve_date('tomorrow@13am'))
-    end)
-
-    it('rejects minute 60', function()
-      assert.is_nil(parse.resolve_date('tomorrow@9:60'))
-    end)
-
-    it('rejects alphabetic garbage', function()
-      assert.is_nil(parse.resolve_date('tomorrow@abc'))
-    end)
   end)
 
   describe('command_add', function()
@@ -415,73 +181,4 @@ describe('parse', function()
       assert.are.equal('2026-03-15', meta.due)
     end)
   end)
-
-  describe('input_date_formats', function()
-    before_each(function()
-      config.reset()
-    end)
-
-    after_each(function()
-      vim.g.pending = nil
-      config.reset()
-    end)
-
-    it('parses MM/DD/YYYY format', function()
-      vim.g.pending = { input_date_formats = { '%m/%d/%Y' } }
-      config.reset()
-      local result = parse.resolve_date('03/15/2026')
-      assert.are.equal('2026-03-15', result)
-    end)
-
-    it('parses DD-Mon-YYYY format', function()
-      vim.g.pending = { input_date_formats = { '%d-%b-%Y' } }
-      config.reset()
-      local result = parse.resolve_date('15-Mar-2026')
-      assert.are.equal('2026-03-15', result)
-    end)
-
-    it('parses month name case-insensitively', function()
-      vim.g.pending = { input_date_formats = { '%d-%b-%Y' } }
-      config.reset()
-      local result = parse.resolve_date('15-MARCH-2026')
-      assert.are.equal('2026-03-15', result)
-    end)
-
-    it('parses two-digit year', function()
-      vim.g.pending = { input_date_formats = { '%m/%d/%y' } }
-      config.reset()
-      local result = parse.resolve_date('03/15/26')
-      assert.are.equal('2026-03-15', result)
-    end)
-
-    it('infers year when format has no year field', function()
-      vim.g.pending = { input_date_formats = { '%m/%d' } }
-      config.reset()
-      local result = parse.resolve_date('12/31')
-      assert.is_not_nil(result)
-      assert.truthy(result:match('^%d%d%d%d%-12%-31$'))
-    end)
-
-    it('returns nil for non-matching input', function()
-      vim.g.pending = { input_date_formats = { '%m/%d/%Y' } }
-      config.reset()
-      local result = parse.resolve_date('not-a-date')
-      assert.is_nil(result)
-    end)
-
-    it('tries formats in order, returns first match', function()
-      vim.g.pending = { input_date_formats = { '%d/%m/%Y', '%m/%d/%Y' } }
-      config.reset()
-      local result = parse.resolve_date('01/03/2026')
-      assert.are.equal('2026-03-01', result)
-    end)
-
-    it('works with body() for inline due token', function()
-      vim.g.pending = { input_date_formats = { '%m/%d/%Y' } }
-      config.reset()
-      local desc, meta = parse.body('Pay rent due:03/15/2026')
-      assert.are.equal('Pay rent', desc)
-      assert.are.equal('2026-03-15', meta.due)
-    end)
-  end)
 end)

spec/recur_spec.lua

@@ -1,223 +0,0 @@
-require('spec.helpers')
-
-describe('recur', function()
-  local recur = require('pending.recur')
-
-  describe('parse', function()
-    it('parses daily', function()
-      local r = recur.parse('daily')
-      assert.are.equal('daily', r.freq)
-      assert.are.equal(1, r.interval)
-      assert.is_false(r.from_completion)
-    end)
-
-    it('parses weekdays', function()
-      local r = recur.parse('weekdays')
-      assert.are.equal('weekly', r.freq)
-      assert.are.same({ 'MO', 'TU', 'WE', 'TH', 'FR' }, r.byday)
-    end)
-
-    it('parses weekly', function()
-      local r = recur.parse('weekly')
-      assert.are.equal('weekly', r.freq)
-      assert.are.equal(1, r.interval)
-    end)
-
-    it('parses biweekly', function()
-      local r = recur.parse('biweekly')
-      assert.are.equal('weekly', r.freq)
-      assert.are.equal(2, r.interval)
-    end)
-
-    it('parses monthly', function()
-      local r = recur.parse('monthly')
-      assert.are.equal('monthly', r.freq)
-      assert.are.equal(1, r.interval)
-    end)
-
-    it('parses quarterly', function()
-      local r = recur.parse('quarterly')
-      assert.are.equal('monthly', r.freq)
-      assert.are.equal(3, r.interval)
-    end)
-
-    it('parses yearly', function()
-      local r = recur.parse('yearly')
-      assert.are.equal('yearly', r.freq)
-      assert.are.equal(1, r.interval)
-    end)
-
-    it('parses annual as yearly', function()
-      local r = recur.parse('annual')
-      assert.are.equal('yearly', r.freq)
-    end)
-
-    it('parses 3d as every 3 days', function()
-      local r = recur.parse('3d')
-      assert.are.equal('daily', r.freq)
-      assert.are.equal(3, r.interval)
-    end)
-
-    it('parses 2w as biweekly', function()
-      local r = recur.parse('2w')
-      assert.are.equal('weekly', r.freq)
-      assert.are.equal(2, r.interval)
-    end)
-
-    it('parses 6m as every 6 months', function()
-      local r = recur.parse('6m')
-      assert.are.equal('monthly', r.freq)
-      assert.are.equal(6, r.interval)
-    end)
-
-    it('parses 2y as every 2 years', function()
-      local r = recur.parse('2y')
-      assert.are.equal('yearly', r.freq)
-      assert.are.equal(2, r.interval)
-    end)
-
-    it('parses ! prefix as completion-based', function()
-      local r = recur.parse('!weekly')
-      assert.are.equal('weekly', r.freq)
-      assert.is_true(r.from_completion)
-    end)
-
-    it('parses raw RRULE fragment', function()
-      local r = recur.parse('FREQ=MONTHLY;BYDAY=1MO')
-      assert.is_not_nil(r)
-    end)
-
-    it('returns nil for invalid input', function()
-      assert.is_nil(recur.parse(''))
-      assert.is_nil(recur.parse('garbage'))
-      assert.is_nil(recur.parse('0d'))
-    end)
-
-    it('is case insensitive', function()
-      local r = recur.parse('Weekly')
-      assert.are.equal('weekly', r.freq)
-    end)
-  end)
-
-  describe('validate', function()
-    it('returns true for valid specs', function()
-      assert.is_true(recur.validate('daily'))
-      assert.is_true(recur.validate('2w'))
-      assert.is_true(recur.validate('!monthly'))
-    end)
-
-    it('returns false for invalid specs', function()
-      assert.is_false(recur.validate('garbage'))
-      assert.is_false(recur.validate(''))
-    end)
-  end)
-
-  describe('next_due', function()
-    it('advances daily by 1 day', function()
-      local result = recur.next_due('2099-03-01', 'daily', 'scheduled')
-      assert.are.equal('2099-03-02', result)
-    end)
-
-    it('advances weekly by 7 days', function()
-      local result = recur.next_due('2099-03-01', 'weekly', 'scheduled')
-      assert.are.equal('2099-03-08', result)
-    end)
-
-    it('advances monthly and clamps day', function()
-      local result = recur.next_due('2099-01-31', 'monthly', 'scheduled')
-      assert.are.equal('2099-02-28', result)
-    end)
-
-    it('advances yearly and handles leap year', function()
-      local result = recur.next_due('2096-02-29', 'yearly', 'scheduled')
-      assert.are.equal('2097-02-28', result)
-    end)
-
-    it('advances biweekly by 14 days', function()
-      local result = recur.next_due('2099-03-01', 'biweekly', 'scheduled')
-      assert.are.equal('2099-03-15', result)
-    end)
-
-    it('advances quarterly by 3 months', function()
-      local result = recur.next_due('2099-01-15', 'quarterly', 'scheduled')
-      assert.are.equal('2099-04-15', result)
-    end)
-
-    it('scheduled mode skips to future if overdue', function()
-      local result = recur.next_due('2020-01-01', 'yearly', 'scheduled')
-      local today = os.date('%Y-%m-%d') --[[@as string]]
-      assert.is_true(result > today)
-    end)
-
-    it('completion mode advances from today', function()
-      local today = os.date('*t') --[[@as osdate]]
-      local expected = os.date(
-        '%Y-%m-%d',
-        os.time({
-          year = today.year,
-          month = today.month,
-          day = today.day + 7,
-        })
-      )
-      local result = recur.next_due('2020-01-01', 'weekly', 'completion')
-      assert.are.equal(expected, result)
-    end)
-
-    it('advances 3d by 3 days', function()
-      local result = recur.next_due('2099-06-10', '3d', 'scheduled')
-      assert.are.equal('2099-06-13', result)
-    end)
-  end)
-
-  describe('to_rrule', function()
-    it('converts daily', function()
-      assert.are.equal('RRULE:FREQ=DAILY', recur.to_rrule('daily'))
-    end)
-
-    it('converts weekly', function()
-      assert.are.equal('RRULE:FREQ=WEEKLY', recur.to_rrule('weekly'))
-    end)
-
-    it('converts biweekly with interval', function()
-      assert.are.equal('RRULE:FREQ=WEEKLY;INTERVAL=2', recur.to_rrule('biweekly'))
-    end)
-
-    it('converts weekdays with BYDAY', function()
-      assert.are.equal('RRULE:FREQ=WEEKLY;BYDAY=MO,TU,WE,TH,FR', recur.to_rrule('weekdays'))
-    end)
-
-    it('converts monthly', function()
-      assert.are.equal('RRULE:FREQ=MONTHLY', recur.to_rrule('monthly'))
-    end)
-
-    it('converts quarterly with interval', function()
-      assert.are.equal('RRULE:FREQ=MONTHLY;INTERVAL=3', recur.to_rrule('quarterly'))
-    end)
-
-    it('converts yearly', function()
-      assert.are.equal('RRULE:FREQ=YEARLY', recur.to_rrule('yearly'))
-    end)
-
-    it('converts 2w with interval', function()
-      assert.are.equal('RRULE:FREQ=WEEKLY;INTERVAL=2', recur.to_rrule('2w'))
-    end)
-
-    it('prefixes raw RRULE fragment', function()
-      assert.are.equal('RRULE:FREQ=MONTHLY;BYDAY=1MO', recur.to_rrule('FREQ=MONTHLY;BYDAY=1MO'))
-    end)
-
-    it('returns empty string for invalid spec', function()
-      assert.are.equal('', recur.to_rrule('garbage'))
-    end)
-  end)
-
-  describe('shorthand_list', function()
-    it('returns a list of named shorthands', function()
-      local list = recur.shorthand_list()
-      assert.is_true(#list >= 8)
-      assert.is_true(vim.tbl_contains(list, 'daily'))
-      assert.is_true(vim.tbl_contains(list, 'weekly'))
-      assert.is_true(vim.tbl_contains(list, 'monthly'))
-    end)
-  end)
-end)

spec/status_spec.lua

@@ -1,260 +0,0 @@
-require('spec.helpers')
-
-local config = require('pending.config')
-local parse = require('pending.parse')
-
-describe('status', function()
-  local tmpdir
-  local pending
-
-  before_each(function()
-    tmpdir = vim.fn.tempname()
-    vim.fn.mkdir(tmpdir, 'p')
-    vim.g.pending = { data_path = tmpdir .. '/tasks.json' }
-    config.reset()
-    package.loaded['pending'] = nil
-    pending = require('pending')
-    pending.store():load()
-  end)
-
-  after_each(function()
-    vim.fn.delete(tmpdir, 'rf')
-    vim.g.pending = nil
-    config.reset()
-    package.loaded['pending'] = nil
-  end)
-
-  describe('counts', function()
-    it('returns zeroes for empty store', function()
-      local c = pending.counts()
-      assert.are.equal(0, c.overdue)
-      assert.are.equal(0, c.today)
-      assert.are.equal(0, c.pending)
-      assert.are.equal(0, c.priority)
-      assert.is_nil(c.next_due)
-    end)
-
-    it('counts pending tasks', function()
-      local s = pending.store()
-      s:add({ description = 'One' })
-      s:add({ description = 'Two' })
-      s:save()
-      pending._recompute_counts()
-      local c = pending.counts()
-      assert.are.equal(2, c.pending)
-    end)
-
-    it('counts priority tasks', function()
-      local s = pending.store()
-      s:add({ description = 'Urgent', priority = 1 })
-      s:add({ description = 'Normal' })
-      s:save()
-      pending._recompute_counts()
-      local c = pending.counts()
-      assert.are.equal(1, c.priority)
-    end)
-
-    it('counts overdue tasks with date-only', function()
-      local s = pending.store()
-      s:add({ description = 'Old task', due = '2020-01-01' })
-      s:save()
-      pending._recompute_counts()
-      local c = pending.counts()
-      assert.are.equal(1, c.overdue)
-    end)
-
-    it('counts overdue tasks with datetime', function()
-      local s = pending.store()
-      s:add({ description = 'Old task', due = '2020-01-01T08:00' })
-      s:save()
-      pending._recompute_counts()
-      local c = pending.counts()
-      assert.are.equal(1, c.overdue)
-    end)
-
-    it('counts today tasks', function()
-      local s = pending.store()
-      local today = os.date('%Y-%m-%d') --[[@as string]]
-      s:add({ description = 'Today task', due = today })
-      s:save()
-      pending._recompute_counts()
-      local c = pending.counts()
-      assert.are.equal(1, c.today)
-      assert.are.equal(0, c.overdue)
-    end)
-
-    it('counts mixed overdue and today', function()
-      local s = pending.store()
-      local today = os.date('%Y-%m-%d') --[[@as string]]
-      s:add({ description = 'Overdue', due = '2020-01-01' })
-      s:add({ description = 'Today', due = today })
-      s:save()
-      pending._recompute_counts()
-      local c = pending.counts()
-      assert.are.equal(1, c.overdue)
-      assert.are.equal(1, c.today)
-    end)
-
-    it('excludes done tasks', function()
-      local s = pending.store()
-      local t = s:add({ description = 'Done', due = '2020-01-01' })
-      s:update(t.id, { status = 'done' })
-      s:save()
-      pending._recompute_counts()
-      local c = pending.counts()
-      assert.are.equal(0, c.overdue)
-      assert.are.equal(0, c.pending)
-    end)
-
-    it('excludes deleted tasks', function()
-      local s = pending.store()
-      local t = s:add({ description = 'Deleted', due = '2020-01-01' })
-      s:delete(t.id)
-      s:save()
-      pending._recompute_counts()
-      local c = pending.counts()
-      assert.are.equal(0, c.overdue)
-      assert.are.equal(0, c.pending)
-    end)
-
-    it('excludes someday sentinel', function()
-      local s = pending.store()
-      s:add({ description = 'Someday', due = '9999-12-30' })
-      s:save()
-      pending._recompute_counts()
-      local c = pending.counts()
-      assert.are.equal(0, c.overdue)
-      assert.are.equal(0, c.today)
-      assert.are.equal(1, c.pending)
-    end)
-
-    it('picks earliest future date as next_due', function()
-      local s = pending.store()
-      local today = os.date('%Y-%m-%d') --[[@as string]]
-      s:add({ description = 'Soon', due = '2099-06-01' })
-      s:add({ description = 'Sooner', due = '2099-03-01' })
-      s:add({ description = 'Today', due = today })
-      s:save()
-      pending._recompute_counts()
-      local c = pending.counts()
-      assert.are.equal(today, c.next_due)
-    end)
-
-    it('lazy loads on first counts() call', function()
-      local path = config.get().data_path
-      local f = io.open(path, 'w')
-      f:write(vim.json.encode({
-        version = 1,
-        next_id = 2,
-        tasks = {
-          {
-            id = 1,
-            description = 'Overdue',
-            status = 'pending',
-            due = '2020-01-01',
-            entry = '2020-01-01T00:00:00Z',
-            modified = '2020-01-01T00:00:00Z',
-          },
-        },
-      }))
-      f:close()
-      package.loaded['pending'] = nil
-      pending = require('pending')
-      local c = pending.counts()
-      assert.are.equal(1, c.overdue)
-    end)
-  end)
-
-  describe('statusline', function()
-    it('returns empty string when nothing actionable', function()
-      local s = pending.store()
-      s:save()
-      pending._recompute_counts()
-      assert.are.equal('', pending.statusline())
-    end)
-
-    it('formats overdue only', function()
-      local s = pending.store()
-      s:add({ description = 'Old', due = '2020-01-01' })
-      s:save()
-      pending._recompute_counts()
-      assert.are.equal('1 overdue', pending.statusline())
-    end)
-
-    it('formats today only', function()
-      local s = pending.store()
-      local today = os.date('%Y-%m-%d') --[[@as string]]
-      s:add({ description = 'Today', due = today })
-      s:save()
-      pending._recompute_counts()
-      assert.are.equal('1 today', pending.statusline())
-    end)
-
-    it('formats overdue and today', function()
-      local s = pending.store()
-      local today = os.date('%Y-%m-%d') --[[@as string]]
-      s:add({ description = 'Old', due = '2020-01-01' })
-      s:add({ description = 'Today', due = today })
-      s:save()
-      pending._recompute_counts()
-      assert.are.equal('1 overdue, 1 today', pending.statusline())
-    end)
-  end)
-
-  describe('has_due', function()
-    it('returns false when nothing due', function()
-      local s = pending.store()
-      s:add({ description = 'Future', due = '2099-01-01' })
-      s:save()
-      pending._recompute_counts()
-      assert.is_false(pending.has_due())
-    end)
-
-    it('returns true when overdue', function()
-      local s = pending.store()
-      s:add({ description = 'Old', due = '2020-01-01' })
-      s:save()
-      pending._recompute_counts()
-      assert.is_true(pending.has_due())
-    end)
-
-    it('returns true when today', function()
-      local s = pending.store()
-      local today = os.date('%Y-%m-%d') --[[@as string]]
-      s:add({ description = 'Now', due = today })
-      s:save()
-      pending._recompute_counts()
-      assert.is_true(pending.has_due())
-    end)
-  end)
-
-  describe('parse.is_overdue', function()
-    it('date before today is overdue', function()
-      assert.is_true(parse.is_overdue('2020-01-01'))
-    end)
-
-    it('date after today is not overdue', function()
-      assert.is_false(parse.is_overdue('2099-01-01'))
-    end)
-
-    it('today date-only is not overdue', function()
-      local today = os.date('%Y-%m-%d') --[[@as string]]
-      assert.is_false(parse.is_overdue(today))
-    end)
-  end)
-
-  describe('parse.is_today', function()
-    it('today date-only is today', function()
-      local today = os.date('%Y-%m-%d') --[[@as string]]
-      assert.is_true(parse.is_today(today))
-    end)
-
-    it('yesterday is not today', function()
-      assert.is_false(parse.is_today('2020-01-01'))
-    end)
-
-    it('tomorrow is not today', function()
-      assert.is_false(parse.is_today('2099-01-01'))
-    end)
-  end)
-end)

spec/store_spec.lua

@@ -5,30 +5,31 @@ local store = require('pending.store')
 
 describe('store', function()
   local tmpdir
-  local s
 
   before_each(function()
     tmpdir = vim.fn.tempname()
     vim.fn.mkdir(tmpdir, 'p')
-    s = store.new(tmpdir .. '/tasks.json')
+    vim.g.pending = { data_path = tmpdir .. '/tasks.json' }
-    s:load()
+    config.reset()
+    store.unload()
   end)
 
   after_each(function()
     vim.fn.delete(tmpdir, 'rf')
+    vim.g.pending = nil
     config.reset()
   end)
 
   describe('load', function()
     it('returns empty data when no file exists', function()
-      local data = s:load()
+      local data = store.load()
       assert.are.equal(1, data.version)
       assert.are.equal(1, data.next_id)
       assert.are.same({}, data.tasks)
     end)
 
     it('loads existing data', function()
-      local path = tmpdir .. '/tasks.json'
+      local path = config.get().data_path
       local f = io.open(path, 'w')
       f:write(vim.json.encode({
         version = 1,
@@ -51,7 +52,7 @@ describe('store', function()
         },
       }))
       f:close()
-      local data = s:load()
+      local data = store.load()
       assert.are.equal(3, data.next_id)
       assert.are.equal(2, #data.tasks)
       assert.are.equal('Pending one', data.tasks[1].description)
@@ -59,7 +60,7 @@ describe('store', function()
     end)
 
     it('preserves unknown fields', function()
-      local path = tmpdir .. '/tasks.json'
+      local path = config.get().data_path
       local f = io.open(path, 'w')
       f:write(vim.json.encode({
         version = 1,
@@ -76,8 +77,8 @@ describe('store', function()
         },
       }))
       f:close()
-      s:load()
+      store.load()
-      local task = s:get(1)
+      local task = store.get(1)
       assert.is_not_nil(task._extra)
       assert.are.equal('hello', task._extra.custom_field)
     end)
@@ -85,8 +86,9 @@ describe('store', function()
 
   describe('add', function()
     it('creates a task with incremented id', function()
-      local t1 = s:add({ description = 'First' })
+      store.load()
-      local t2 = s:add({ description = 'Second' })
+      local t1 = store.add({ description = 'First' })
+      local t2 = store.add({ description = 'Second' })
       assert.are.equal(1, t1.id)
       assert.are.equal(2, t2.id)
       assert.are.equal('pending', t1.status)
@@ -94,54 +96,60 @@ describe('store', function()
     end)
 
     it('uses provided category', function()
-      local t = s:add({ description = 'Test', category = 'Work' })
+      store.load()
+      local t = store.add({ description = 'Test', category = 'Work' })
       assert.are.equal('Work', t.category)
     end)
   end)
 
   describe('update', function()
     it('updates fields and sets modified', function()
-      local t = s:add({ description = 'Original' })
+      store.load()
+      local t = store.add({ description = 'Original' })
       t.modified = '2025-01-01T00:00:00Z'
-      s:update(t.id, { description = 'Updated' })
+      store.update(t.id, { description = 'Updated' })
-      local updated = s:get(t.id)
+      local updated = store.get(t.id)
       assert.are.equal('Updated', updated.description)
       assert.is_not.equal('2025-01-01T00:00:00Z', updated.modified)
     end)
 
     it('sets end timestamp on completion', function()
-      local t = s:add({ description = 'Test' })
+      store.load()
+      local t = store.add({ description = 'Test' })
       assert.is_nil(t['end'])
-      s:update(t.id, { status = 'done' })
+      store.update(t.id, { status = 'done' })
-      local updated = s:get(t.id)
+      local updated = store.get(t.id)
       assert.is_not_nil(updated['end'])
     end)
 
     it('does not overwrite id or entry', function()
-      local t = s:add({ description = 'Immutable fields' })
+      store.load()
+      local t = store.add({ description = 'Immutable fields' })
       local original_id = t.id
       local original_entry = t.entry
-      s:update(t.id, { id = 999, entry = 'x' })
+      store.update(t.id, { id = 999, entry = 'x' })
-      local updated = s:get(original_id)
+      local updated = store.get(original_id)
       assert.are.equal(original_id, updated.id)
       assert.are.equal(original_entry, updated.entry)
     end)
 
     it('does not overwrite end on second completion', function()
-      local t = s:add({ description = 'Complete twice' })
+      store.load()
-      s:update(t.id, { status = 'done', ['end'] = '2026-01-15T10:00:00Z' })
+      local t = store.add({ description = 'Complete twice' })
-      local first_end = s:get(t.id)['end']
+      store.update(t.id, { status = 'done', ['end'] = '2026-01-15T10:00:00Z' })
-      s:update(t.id, { status = 'done' })
+      local first_end = store.get(t.id)['end']
-      local task = s:get(t.id)
+      store.update(t.id, { status = 'done' })
+      local task = store.get(t.id)
       assert.are.equal(first_end, task['end'])
     end)
   end)
 
   describe('delete', function()
     it('marks task as deleted', function()
-      local t = s:add({ description = 'To delete' })
+      store.load()
-      s:delete(t.id)
+      local t = store.add({ description = 'To delete' })
-      local deleted = s:get(t.id)
+      store.delete(t.id)
+      local deleted = store.get(t.id)
       assert.are.equal('deleted', deleted.status)
       assert.is_not_nil(deleted['end'])
     end)
@@ -149,10 +157,12 @@ describe('store', function()
 
   describe('save and round-trip', function()
     it('persists and reloads correctly', function()
-      s:add({ description = 'Persisted', category = 'Work', priority = 1 })
+      store.load()
-      s:save()
+      store.add({ description = 'Persisted', category = 'Work', priority = 1 })
-      s:load()
+      store.save()
-      local tasks = s:active_tasks()
+      store.unload()
+      store.load()
+      local tasks = store.active_tasks()
       assert.are.equal(1, #tasks)
       assert.are.equal('Persisted', tasks[1].description)
       assert.are.equal('Work', tasks[1].category)
@@ -160,7 +170,7 @@ describe('store', function()
     end)
 
     it('round-trips unknown fields', function()
-      local path = tmpdir .. '/tasks.json'
+      local path = config.get().data_path
       local f = io.open(path, 'w')
       f:write(vim.json.encode({
         version = 1,
@@ -177,49 +187,22 @@ describe('store', function()
         },
       }))
       f:close()
-      s:load()
+      store.load()
-      s:save()
+      store.save()
-      s:load()
+      store.unload()
-      local task = s:get(1)
+      store.load()
+      local task = store.get(1)
       assert.are.equal('abc123', task._extra._gcal_event_id)
     end)
   end)
 
-  describe('recurrence fields', function()
-    it('persists recur and recur_mode through round-trip', function()
-      s:add({ description = 'Recurring', recur = 'weekly', recur_mode = 'scheduled' })
-      s:save()
-      s:load()
-      local task = s:get(1)
-      assert.are.equal('weekly', task.recur)
-      assert.are.equal('scheduled', task.recur_mode)
-    end)
-
-    it('persists recur without recur_mode', function()
-      s:add({ description = 'Simple recur', recur = 'daily' })
-      s:save()
-      s:load()
-      local task = s:get(1)
-      assert.are.equal('daily', task.recur)
-      assert.is_nil(task.recur_mode)
-    end)
-
-    it('omits recur fields when not set', function()
-      s:add({ description = 'No recur' })
-      s:save()
-      s:load()
-      local task = s:get(1)
-      assert.is_nil(task.recur)
-      assert.is_nil(task.recur_mode)
-    end)
-  end)
-
   describe('active_tasks', function()
     it('excludes deleted tasks', function()
-      s:add({ description = 'Active' })
+      store.load()
-      local t2 = s:add({ description = 'To delete' })
+      store.add({ description = 'Active' })
-      s:delete(t2.id)
+      local t2 = store.add({ description = 'To delete' })
-      local active = s:active_tasks()
+      store.delete(t2.id)
+      local active = store.active_tasks()
       assert.are.equal(1, #active)
       assert.are.equal('Active', active[1].description)
     end)
@@ -227,24 +210,27 @@ describe('store', function()
 
   describe('snapshot', function()
     it('returns a table of tasks', function()
-      s:add({ description = 'Snap one' })
+      store.load()
-      s:add({ description = 'Snap two' })
+      store.add({ description = 'Snap one' })
-      local snap = s:snapshot()
+      store.add({ description = 'Snap two' })
+      local snap = store.snapshot()
       assert.are.equal(2, #snap)
     end)
 
     it('returns a copy that does not affect the store', function()
-      local t = s:add({ description = 'Original' })
+      store.load()
-      local snap = s:snapshot()
+      local t = store.add({ description = 'Original' })
+      local snap = store.snapshot()
       snap[1].description = 'Mutated'
-      local live = s:get(t.id)
+      local live = store.get(t.id)
       assert.are.equal('Original', live.description)
     end)
 
     it('excludes deleted tasks', function()
-      local t = s:add({ description = 'Will be deleted' })
+      store.load()
-      s:delete(t.id)
+      local t = store.add({ description = 'Will be deleted' })
-      local snap = s:snapshot()
+      store.delete(t.id)
+      local snap = store.snapshot()
       assert.are.equal(0, #snap)
     end)
   end)

spec/sync_spec.lua

@@ -1,114 +0,0 @@
-require('spec.helpers')
-
-local config = require('pending.config')
-
-describe('sync', function()
-  local tmpdir
-  local pending
-
-  before_each(function()
-    tmpdir = vim.fn.tempname()
-    vim.fn.mkdir(tmpdir, 'p')
-    vim.g.pending = { data_path = tmpdir .. '/tasks.json' }
-    config.reset()
-    package.loaded['pending'] = nil
-    pending = require('pending')
-  end)
-
-  after_each(function()
-    vim.fn.delete(tmpdir, 'rf')
-    vim.g.pending = nil
-    config.reset()
-    package.loaded['pending'] = nil
-  end)
-
-  describe('dispatch', function()
-    it('errors on unknown subcommand', function()
-      local msg
-      local orig = vim.notify
-      vim.notify = function(m, level)
-        if level == vim.log.levels.ERROR then
-          msg = m
-        end
-      end
-      pending.command('notreal')
-      vim.notify = orig
-      assert.are.equal('[pending.nvim]: Unknown Pending subcommand: notreal', msg)
-    end)
-
-    it('errors on unknown action for valid backend', function()
-      local msg
-      local orig = vim.notify
-      vim.notify = function(m, level)
-        if level == vim.log.levels.ERROR then
-          msg = m
-        end
-      end
-      pending.command('gcal notreal')
-      vim.notify = orig
-      assert.are.equal("[pending.nvim]: gcal backend has no 'notreal' action", msg)
-    end)
-
-    it('lists actions when action is omitted', function()
-      local msg = nil
-      local orig = vim.notify
-      vim.notify = function(m)
-        msg = m
-      end
-      pending.command('gcal')
-      vim.notify = orig
-      assert.is_not_nil(msg)
-      assert.is_truthy(msg:find('push'))
-    end)
-
-    it('routes explicit push action', function()
-      local called = false
-      local gcal = require('pending.sync.gcal')
-      local orig_push = gcal.push
-      gcal.push = function()
-        called = true
-      end
-      pending.command('gcal push')
-      gcal.push = orig_push
-      assert.is_true(called)
-    end)
-
-    it('routes auth command', function()
-      local called = false
-      local orig_auth = pending.auth
-      pending.auth = function()
-        called = true
-      end
-      pending.command('auth')
-      pending.auth = orig_auth
-      assert.is_true(called)
-    end)
-  end)
-
-  it('works with sync.gcal config', function()
-    config.reset()
-    vim.g.pending = {
-      data_path = tmpdir .. '/tasks.json',
-      sync = { gcal = { client_id = 'test-id' } },
-    }
-    local cfg = config.get()
-    assert.are.equal('test-id', cfg.sync.gcal.client_id)
-  end)
-
-  describe('gcal module', function()
-    it('has name field', function()
-      local gcal = require('pending.sync.gcal')
-      assert.are.equal('gcal', gcal.name)
-    end)
-
-    it('has push function', function()
-      local gcal = require('pending.sync.gcal')
-      assert.are.equal('function', type(gcal.push))
-    end)
-
-    it('has health function', function()
-      local gcal = require('pending.sync.gcal')
-      assert.are.equal('function', type(gcal.health))
-    end)
-  end)
-end)

spec/textobj_spec.lua

@@ -1,194 +0,0 @@
-require('spec.helpers')
-
-local config = require('pending.config')
-
-describe('textobj', function()
-  local textobj = require('pending.textobj')
-
-  before_each(function()
-    vim.g.pending = nil
-    config.reset()
-  end)
-
-  after_each(function()
-    vim.g.pending = nil
-    config.reset()
-  end)
-
-  describe('inner_task_range', function()
-    it('returns description range for task with id prefix', function()
-      local s, e = textobj.inner_task_range('/1/- [ ] Buy groceries')
-      assert.are.equal(10, s)
-      assert.are.equal(22, e)
-    end)
-
-    it('returns description range for task without id prefix', function()
-      local s, e = textobj.inner_task_range('- [ ] Buy groceries')
-      assert.are.equal(7, s)
-      assert.are.equal(19, e)
-    end)
-
-    it('excludes trailing due: token', function()
-      local s, e = textobj.inner_task_range('/1/- [ ] Buy groceries due:2026-03-15')
-      assert.are.equal(10, s)
-      assert.are.equal(22, e)
-    end)
-
-    it('excludes trailing cat: token', function()
-      local s, e = textobj.inner_task_range('/1/- [ ] Buy groceries cat:Errands')
-      assert.are.equal(10, s)
-      assert.are.equal(22, e)
-    end)
-
-    it('excludes trailing rec: token', function()
-      local s, e = textobj.inner_task_range('/1/- [ ] Take out trash rec:weekly')
-      assert.are.equal(10, s)
-      assert.are.equal(23, e)
-    end)
-
-    it('excludes multiple trailing metadata tokens', function()
-      local s, e =
-        textobj.inner_task_range('/1/- [ ] Buy milk due:2026-03-15 cat:Errands rec:weekly')
-      assert.are.equal(10, s)
-      assert.are.equal(17, e)
-    end)
-
-    it('handles priority checkbox', function()
-      local s, e = textobj.inner_task_range('/1/- [!] Important task')
-      assert.are.equal(10, s)
-      assert.are.equal(23, e)
-    end)
-
-    it('handles done checkbox', function()
-      local s, e = textobj.inner_task_range('/1/- [x] Finished task')
-      assert.are.equal(10, s)
-      assert.are.equal(22, e)
-    end)
-
-    it('handles multi-digit task ids', function()
-      local s, e = textobj.inner_task_range('/123/- [ ] Some task')
-      assert.are.equal(12, s)
-      assert.are.equal(20, e)
-    end)
-
-    it('does not strip non-metadata tokens', function()
-      local s, e = textobj.inner_task_range('/1/- [ ] Buy groceries for dinner')
-      assert.are.equal(10, s)
-      assert.are.equal(33, e)
-    end)
-
-    it('stops stripping at first non-metadata token from right', function()
-      local s, e = textobj.inner_task_range('/1/- [ ] Buy groceries for dinner due:2026-03-15')
-      assert.are.equal(10, s)
-      assert.are.equal(33, e)
-    end)
-
-    it('respects custom date_syntax', function()
-      vim.g.pending = { date_syntax = 'by' }
-      config.reset()
-      local s, e = textobj.inner_task_range('/1/- [ ] Buy groceries by:2026-03-15')
-      assert.are.equal(10, s)
-      assert.are.equal(22, e)
-    end)
-
-    it('respects custom recur_syntax', function()
-      vim.g.pending = { recur_syntax = 'repeat' }
-      config.reset()
-      local s, e = textobj.inner_task_range('/1/- [ ] Take trash repeat:weekly')
-      assert.are.equal(10, s)
-      assert.are.equal(19, e)
-    end)
-
-    it('handles task with only metadata after description', function()
-      local s, e = textobj.inner_task_range('/1/- [ ] X due:tomorrow')
-      assert.are.equal(10, s)
-      assert.are.equal(10, e)
-    end)
-  end)
-
-  describe('category_bounds', function()
-    it('returns header and last row for single category', function()
-      ---@type pending.LineMeta[]
-      local meta = {
-        { type = 'header', category = 'Work' },
-        { type = 'task', id = 1 },
-        { type = 'task', id = 2 },
-      }
-      local h, l = textobj.category_bounds(2, meta)
-      assert.are.equal(1, h)
-      assert.are.equal(3, l)
-    end)
-
-    it('returns bounds for first category with trailing blank', function()
-      ---@type pending.LineMeta[]
-      local meta = {
-        { type = 'header', category = 'Work' },
-        { type = 'task', id = 1 },
-        { type = 'blank' },
-        { type = 'header', category = 'Personal' },
-        { type = 'task', id = 2 },
-      }
-      local h, l = textobj.category_bounds(2, meta)
-      assert.are.equal(1, h)
-      assert.are.equal(3, l)
-    end)
-
-    it('returns bounds for second category', function()
-      ---@type pending.LineMeta[]
-      local meta = {
-        { type = 'header', category = 'Work' },
-        { type = 'task', id = 1 },
-        { type = 'blank' },
-        { type = 'header', category = 'Personal' },
-        { type = 'task', id = 2 },
-        { type = 'task', id = 3 },
-      }
-      local h, l = textobj.category_bounds(5, meta)
-      assert.are.equal(4, h)
-      assert.are.equal(6, l)
-    end)
-
-    it('returns bounds when cursor is on header', function()
-      ---@type pending.LineMeta[]
-      local meta = {
-        { type = 'header', category = 'Work' },
-        { type = 'task', id = 1 },
-      }
-      local h, l = textobj.category_bounds(1, meta)
-      assert.are.equal(1, h)
-      assert.are.equal(2, l)
-    end)
-
-    it('returns nil for blank line with no preceding header', function()
-      ---@type pending.LineMeta[]
-      local meta = {
-        { type = 'blank' },
-        { type = 'header', category = 'Work' },
-        { type = 'task', id = 1 },
-      }
-      local h, l = textobj.category_bounds(1, meta)
-      assert.is_nil(h)
-      assert.is_nil(l)
-    end)
-
-    it('returns nil for empty meta', function()
-      local h, l = textobj.category_bounds(1, {})
-      assert.is_nil(h)
-      assert.is_nil(l)
-    end)
-
-    it('includes blank between header and next header in bounds', function()
-      ---@type pending.LineMeta[]
-      local meta = {
-        { type = 'header', category = 'Work' },
-        { type = 'task', id = 1 },
-        { type = 'blank' },
-        { type = 'header', category = 'Home' },
-        { type = 'task', id = 2 },
-      }
-      local h, l = textobj.category_bounds(1, meta)
-      assert.are.equal(1, h)
-      assert.are.equal(3, l)
-    end)
-  end)
-end)

spec/views_spec.lua

@@ -5,38 +5,39 @@ local store = require('pending.store')
 
 describe('views', function()
   local tmpdir
-  local s
   local views = require('pending.views')
 
   before_each(function()
     tmpdir = vim.fn.tempname()
     vim.fn.mkdir(tmpdir, 'p')
+    vim.g.pending = { data_path = tmpdir .. '/tasks.json' }
     config.reset()
-    s = store.new(tmpdir .. '/tasks.json')
+    store.unload()
-    s:load()
+    store.load()
   end)
 
   after_each(function()
     vim.fn.delete(tmpdir, 'rf')
+    vim.g.pending = nil
     config.reset()
   end)
 
   describe('category_view', function()
     it('groups tasks under their category header', function()
-      s:add({ description = 'Task A', category = 'Work' })
+      store.add({ description = 'Task A', category = 'Work' })
-      s:add({ description = 'Task B', category = 'Work' })
+      store.add({ description = 'Task B', category = 'Work' })
-      local lines, meta = views.category_view(s:active_tasks())
+      local lines, meta = views.category_view(store.active_tasks())
-      assert.are.equal('# Work', lines[1])
+      assert.are.equal('## Work', lines[1])
       assert.are.equal('header', meta[1].type)
       assert.is_true(lines[2]:find('Task A') ~= nil)
       assert.is_true(lines[3]:find('Task B') ~= nil)
     end)
 
     it('places pending tasks before done tasks within a category', function()
-      local t1 = s:add({ description = 'Done task', category = 'Work' })
+      local t1 = store.add({ description = 'Done task', category = 'Work' })
-      s:add({ description = 'Pending task', category = 'Work' })
+      store.add({ description = 'Pending task', category = 'Work' })
-      s:update(t1.id, { status = 'done' })
+      store.update(t1.id, { status = 'done' })
-      local _, meta = views.category_view(s:active_tasks())
+      local _, meta = views.category_view(store.active_tasks())
       local pending_row, done_row
       for i, m in ipairs(meta) do
         if m.type == 'task' and m.status == 'pending' then
@@ -49,9 +50,9 @@ describe('views', function()
     end)
 
     it('sorts high-priority tasks before normal tasks within pending group', function()
-      s:add({ description = 'Normal', category = 'Work', priority = 0 })
+      store.add({ description = 'Normal', category = 'Work', priority = 0 })
-      s:add({ description = 'High', category = 'Work', priority = 1 })
+      store.add({ description = 'High', category = 'Work', priority = 1 })
-      local lines, meta = views.category_view(s:active_tasks())
+      local lines, meta = views.category_view(store.active_tasks())
       local high_row, normal_row
       for i, m in ipairs(meta) do
         if m.type == 'task' then
@@ -67,11 +68,11 @@ describe('views', function()
     end)
 
     it('sorts high-priority tasks before normal tasks within done group', function()
-      local t1 = s:add({ description = 'Done Normal', category = 'Work', priority = 0 })
+      local t1 = store.add({ description = 'Done Normal', category = 'Work', priority = 0 })
-      local t2 = s:add({ description = 'Done High', category = 'Work', priority = 1 })
+      local t2 = store.add({ description = 'Done High', category = 'Work', priority = 1 })
-      s:update(t1.id, { status = 'done' })
+      store.update(t1.id, { status = 'done' })
-      s:update(t2.id, { status = 'done' })
+      store.update(t2.id, { status = 'done' })
-      local lines, meta = views.category_view(s:active_tasks())
+      local lines, meta = views.category_view(store.active_tasks())
       local high_row, normal_row
       for i, m in ipairs(meta) do
         if m.type == 'task' then
@@ -87,9 +88,9 @@ describe('views', function()
     end)
 
     it('gives each category its own header with blank lines between them', function()
-      s:add({ description = 'Task A', category = 'Work' })
+      store.add({ description = 'Task A', category = 'Work' })
-      s:add({ description = 'Task B', category = 'Personal' })
+      store.add({ description = 'Task B', category = 'Personal' })
-      local lines, meta = views.category_view(s:active_tasks())
+      local lines, meta = views.category_view(store.active_tasks())
       local headers = {}
       local blank_found = false
       for i, m in ipairs(meta) do
@@ -104,8 +105,8 @@ describe('views', function()
     end)
 
     it('formats task lines as /ID/  description', function()
-      s:add({ description = 'My task', category = 'Inbox' })
+      store.add({ description = 'My task', category = 'Inbox' })
-      local lines, meta = views.category_view(s:active_tasks())
+      local lines, meta = views.category_view(store.active_tasks())
       local task_line
       for i, m in ipairs(meta) do
         if m.type == 'task' then
@@ -116,8 +117,8 @@ describe('views', function()
     end)
 
     it('formats priority task lines as /ID/- [!] description', function()
-      s:add({ description = 'Important', category = 'Inbox', priority = 1 })
+      store.add({ description = 'Important', category = 'Inbox', priority = 1 })
-      local lines, meta = views.category_view(s:active_tasks())
+      local lines, meta = views.category_view(store.active_tasks())
       local task_line
       for i, m in ipairs(meta) do
         if m.type == 'task' then
@@ -128,15 +129,15 @@ describe('views', function()
     end)
 
     it('sets LineMeta type=header for header lines with correct category', function()
-      s:add({ description = 'T', category = 'School' })
+      store.add({ description = 'T', category = 'School' })
-      local _, meta = views.category_view(s:active_tasks())
+      local _, meta = views.category_view(store.active_tasks())
       assert.are.equal('header', meta[1].type)
       assert.are.equal('School', meta[1].category)
     end)
 
     it('sets LineMeta type=task with correct id and status', function()
-      local t = s:add({ description = 'Do something', category = 'Inbox' })
+      local t = store.add({ description = 'Do something', category = 'Inbox' })
-      local _, meta = views.category_view(s:active_tasks())
+      local _, meta = views.category_view(store.active_tasks())
       local task_meta
       for _, m in ipairs(meta) do
         if m.type == 'task' then
@@ -149,9 +150,9 @@ describe('views', function()
     end)
 
     it('sets LineMeta type=blank for blank separator lines', function()
-      s:add({ description = 'A', category = 'Work' })
+      store.add({ description = 'A', category = 'Work' })
-      s:add({ description = 'B', category = 'Home' })
+      store.add({ description = 'B', category = 'Home' })
-      local _, meta = views.category_view(s:active_tasks())
+      local _, meta = views.category_view(store.active_tasks())
       local blank_meta
       for _, m in ipairs(meta) do
         if m.type == 'blank' then
@@ -165,8 +166,8 @@ describe('views', function()
 
     it('marks overdue pending tasks with meta.overdue=true', function()
       local yesterday = os.date('%Y-%m-%d', os.time() - 86400)
-      local t = s:add({ description = 'Overdue task', category = 'Inbox', due = yesterday })
+      local t = store.add({ description = 'Overdue task', category = 'Inbox', due = yesterday })
-      local _, meta = views.category_view(s:active_tasks())
+      local _, meta = views.category_view(store.active_tasks())
       local task_meta
       for _, m in ipairs(meta) do
         if m.type == 'task' and m.id == t.id then
@@ -178,8 +179,8 @@ describe('views', function()
 
     it('does not mark future pending tasks as overdue', function()
       local tomorrow = os.date('%Y-%m-%d', os.time() + 86400)
-      local t = s:add({ description = 'Future task', category = 'Inbox', due = tomorrow })
+      local t = store.add({ description = 'Future task', category = 'Inbox', due = tomorrow })
-      local _, meta = views.category_view(s:active_tasks())
+      local _, meta = views.category_view(store.active_tasks())
       local task_meta
       for _, m in ipairs(meta) do
         if m.type == 'task' and m.id == t.id then
@@ -191,9 +192,9 @@ describe('views', function()
 
     it('does not mark done tasks with overdue due dates as overdue', function()
       local yesterday = os.date('%Y-%m-%d', os.time() - 86400)
-      local t = s:add({ description = 'Done late', category = 'Inbox', due = yesterday })
+      local t = store.add({ description = 'Done late', category = 'Inbox', due = yesterday })
-      s:update(t.id, { status = 'done' })
+      store.update(t.id, { status = 'done' })
-      local _, meta = views.category_view(s:active_tasks())
+      local _, meta = views.category_view(store.active_tasks())
       local task_meta
       for _, m in ipairs(meta) do
         if m.type == 'task' and m.id == t.id then
@@ -203,36 +204,12 @@ describe('views', function()
       assert.is_falsy(task_meta.overdue)
     end)
 
-    it('includes recur in LineMeta for recurring tasks', function()
-      s:add({ description = 'Recurring', category = 'Inbox', recur = 'weekly' })
-      local _, meta = views.category_view(s:active_tasks())
-      local task_meta
-      for _, m in ipairs(meta) do
-        if m.type == 'task' then
-          task_meta = m
-        end
-      end
-      assert.are.equal('weekly', task_meta.recur)
-    end)
-
-    it('has nil recur in LineMeta for non-recurring tasks', function()
-      s:add({ description = 'Normal', category = 'Inbox' })
-      local _, meta = views.category_view(s:active_tasks())
-      local task_meta
-      for _, m in ipairs(meta) do
-        if m.type == 'task' then
-          task_meta = m
-        end
-      end
-      assert.is_nil(task_meta.recur)
-    end)
-
     it('respects category_order when set', function()
       vim.g.pending = { data_path = tmpdir .. '/tasks.json', category_order = { 'Work', 'Inbox' } }
       config.reset()
-      s:add({ description = 'Inbox task', category = 'Inbox' })
+      store.add({ description = 'Inbox task', category = 'Inbox' })
-      s:add({ description = 'Work task', category = 'Work' })
+      store.add({ description = 'Work task', category = 'Work' })
-      local lines, meta = views.category_view(s:active_tasks())
+      local lines, meta = views.category_view(store.active_tasks())
       local first_header, second_header
       for i, m in ipairs(meta) do
         if m.type == 'header' then
@@ -243,47 +220,47 @@ describe('views', function()
           end
         end
       end
-      assert.are.equal('# Work', first_header)
+      assert.are.equal('## Work', first_header)
-      assert.are.equal('# Inbox', second_header)
+      assert.are.equal('## Inbox', second_header)
     end)
 
     it('appends categories not in category_order after ordered ones', function()
       vim.g.pending = { data_path = tmpdir .. '/tasks.json', category_order = { 'Work' } }
       config.reset()
-      s:add({ description = 'Errand', category = 'Errands' })
+      store.add({ description = 'Errand', category = 'Errands' })
-      s:add({ description = 'Work task', category = 'Work' })
+      store.add({ description = 'Work task', category = 'Work' })
-      local lines, meta = views.category_view(s:active_tasks())
+      local lines, meta = views.category_view(store.active_tasks())
       local headers = {}
       for i, m in ipairs(meta) do
         if m.type == 'header' then
           table.insert(headers, lines[i])
         end
       end
-      assert.are.equal('# Work', headers[1])
+      assert.are.equal('## Work', headers[1])
-      assert.are.equal('# Errands', headers[2])
+      assert.are.equal('## Errands', headers[2])
     end)
 
     it('preserves insertion order when category_order is empty', function()
-      s:add({ description = 'Alpha task', category = 'Alpha' })
+      store.add({ description = 'Alpha task', category = 'Alpha' })
-      s:add({ description = 'Beta task', category = 'Beta' })
+      store.add({ description = 'Beta task', category = 'Beta' })
-      local lines, meta = views.category_view(s:active_tasks())
+      local lines, meta = views.category_view(store.active_tasks())
       local headers = {}
       for i, m in ipairs(meta) do
         if m.type == 'header' then
           table.insert(headers, lines[i])
         end
       end
-      assert.are.equal('# Alpha', headers[1])
+      assert.are.equal('## Alpha', headers[1])
-      assert.are.equal('# Beta', headers[2])
+      assert.are.equal('## Beta', headers[2])
     end)
   end)
 
   describe('priority_view', function()
     it('places all pending tasks before done tasks', function()
-      local t1 = s:add({ description = 'Done A', category = 'Work' })
+      local t1 = store.add({ description = 'Done A', category = 'Work' })
-      s:add({ description = 'Pending B', category = 'Work' })
+      store.add({ description = 'Pending B', category = 'Work' })
-      s:update(t1.id, { status = 'done' })
+      store.update(t1.id, { status = 'done' })
-      local _, meta = views.priority_view(s:active_tasks())
+      local _, meta = views.priority_view(store.active_tasks())
       local last_pending_row, first_done_row
       for i, m in ipairs(meta) do
         if m.type == 'task' then
@@ -298,9 +275,9 @@ describe('views', function()
     end)
 
     it('sorts pending tasks by priority desc within pending group', function()
-      s:add({ description = 'Low', category = 'Work', priority = 0 })
+      store.add({ description = 'Low', category = 'Work', priority = 0 })
-      s:add({ description = 'High', category = 'Work', priority = 1 })
+      store.add({ description = 'High', category = 'Work', priority = 1 })
-      local lines, meta = views.priority_view(s:active_tasks())
+      local lines, meta = views.priority_view(store.active_tasks())
       local high_row, low_row
       for i, m in ipairs(meta) do
         if m.type == 'task' then
@@ -315,9 +292,9 @@ describe('views', function()
     end)
 
     it('sorts pending tasks with due dates before those without', function()
-      s:add({ description = 'No due', category = 'Work' })
+      store.add({ description = 'No due', category = 'Work' })
-      s:add({ description = 'Has due', category = 'Work', due = '2099-12-31' })
+      store.add({ description = 'Has due', category = 'Work', due = '2099-12-31' })
-      local lines, meta = views.priority_view(s:active_tasks())
+      local lines, meta = views.priority_view(store.active_tasks())
       local due_row, nodue_row
       for i, m in ipairs(meta) do
         if m.type == 'task' then
@@ -332,9 +309,9 @@ describe('views', function()
     end)
 
     it('sorts pending tasks with earlier due dates before later due dates', function()
-      s:add({ description = 'Later', category = 'Work', due = '2099-12-31' })
+      store.add({ description = 'Later', category = 'Work', due = '2099-12-31' })
-      s:add({ description = 'Earlier', category = 'Work', due = '2050-01-01' })
+      store.add({ description = 'Earlier', category = 'Work', due = '2050-01-01' })
-      local lines, meta = views.priority_view(s:active_tasks())
+      local lines, meta = views.priority_view(store.active_tasks())
       local earlier_row, later_row
       for i, m in ipairs(meta) do
         if m.type == 'task' then
@@ -349,15 +326,15 @@ describe('views', function()
     end)
 
     it('formats task lines as /ID/- [ ] description', function()
-      s:add({ description = 'My task', category = 'Inbox' })
+      store.add({ description = 'My task', category = 'Inbox' })
-      local lines, _ = views.priority_view(s:active_tasks())
+      local lines, _ = views.priority_view(store.active_tasks())
       assert.are.equal('/1/- [ ] My task', lines[1])
     end)
 
     it('sets show_category=true for all task meta entries', function()
-      s:add({ description = 'T1', category = 'Work' })
+      store.add({ description = 'T1', category = 'Work' })
-      s:add({ description = 'T2', category = 'Personal' })
+      store.add({ description = 'T2', category = 'Personal' })
-      local _, meta = views.priority_view(s:active_tasks())
+      local _, meta = views.priority_view(store.active_tasks())
       for _, m in ipairs(meta) do
         if m.type == 'task' then
           assert.is_true(m.show_category == true)
@@ -366,9 +343,9 @@ describe('views', function()
     end)
 
     it('sets meta.category correctly for each task', function()
-      s:add({ description = 'Work task', category = 'Work' })
+      store.add({ description = 'Work task', category = 'Work' })
-      s:add({ description = 'Home task', category = 'Home' })
+      store.add({ description = 'Home task', category = 'Home' })
-      local lines, meta = views.priority_view(s:active_tasks())
+      local lines, meta = views.priority_view(store.active_tasks())
       local categories = {}
       for i, m in ipairs(meta) do
         if m.type == 'task' then
@@ -385,8 +362,8 @@ describe('views', function()
 
     it('marks overdue pending tasks with meta.overdue=true', function()
       local yesterday = os.date('%Y-%m-%d', os.time() - 86400)
-      local t = s:add({ description = 'Overdue', category = 'Inbox', due = yesterday })
+      local t = store.add({ description = 'Overdue', category = 'Inbox', due = yesterday })
-      local _, meta = views.priority_view(s:active_tasks())
+      local _, meta = views.priority_view(store.active_tasks())
       local task_meta
       for _, m in ipairs(meta) do
         if m.type == 'task' and m.id == t.id then
@@ -398,8 +375,8 @@ describe('views', function()
 
     it('does not mark future pending tasks as overdue', function()
       local tomorrow = os.date('%Y-%m-%d', os.time() + 86400)
-      local t = s:add({ description = 'Future', category = 'Inbox', due = tomorrow })
+      local t = store.add({ description = 'Future', category = 'Inbox', due = tomorrow })
-      local _, meta = views.priority_view(s:active_tasks())
+      local _, meta = views.priority_view(store.active_tasks())
       local task_meta
       for _, m in ipairs(meta) do
         if m.type == 'task' and m.id == t.id then
@@ -411,9 +388,9 @@ describe('views', function()
 
     it('does not mark done tasks with overdue due dates as overdue', function()
       local yesterday = os.date('%Y-%m-%d', os.time() - 86400)
-      local t = s:add({ description = 'Done late', category = 'Inbox', due = yesterday })
+      local t = store.add({ description = 'Done late', category = 'Inbox', due = yesterday })
-      s:update(t.id, { status = 'done' })
+      store.update(t.id, { status = 'done' })
-      local _, meta = views.priority_view(s:active_tasks())
+      local _, meta = views.priority_view(store.active_tasks())
       local task_meta
       for _, m in ipairs(meta) do
         if m.type == 'task' and m.id == t.id then
@@ -422,29 +399,5 @@ describe('views', function()
       end
       assert.is_falsy(task_meta.overdue)
     end)
-
-    it('includes recur in LineMeta for recurring tasks', function()
-      s:add({ description = 'Recurring', category = 'Inbox', recur = 'daily' })
-      local _, meta = views.priority_view(s:active_tasks())
-      local task_meta
-      for _, m in ipairs(meta) do
-        if m.type == 'task' then
-          task_meta = m
-        end
-      end
-      assert.are.equal('daily', task_meta.recur)
-    end)
-
-    it('has nil recur in LineMeta for non-recurring tasks', function()
-      s:add({ description = 'Normal', category = 'Inbox' })
-      local _, meta = views.priority_view(s:active_tasks())
-      local task_meta
-      for _, m in ipairs(meta) do
-        if m.type == 'task' then
-          task_meta = m
-        end
-      end
-      assert.is_nil(task_meta.recur)
-    end)
   end)
 end)