-- syscalls shared by BSD based operating systems

local require, error, assert, tonumber, tostring,
setmetatable, pairs, ipairs, unpack, rawget, rawset,
pcall, type, table, string = 
require, error, assert, tonumber, tostring,
setmetatable, pairs, ipairs, unpack, rawget, rawset,
pcall, type, table, string

local abi = require "syscall.abi"

return function(S, hh, c, C, types)

local ret64, retnum, retfd, retbool, retptr, retiter = hh.ret64, hh.retnum, hh.retfd, hh.retbool, hh.retptr, hh.retiter

local ffi = require "ffi"
local errno = ffi.errno

local h = require "syscall.helpers"

local istype, mktype, getfd = h.istype, h.mktype, h.getfd
local octal, split = h.octal, h.split

local t, pt, s = types.t, types.pt, types.s

-- note emulated in libc in NetBSD
if C.getdirentries then
  function S.getdirentries(fd, buf, size, basep)
    size = size or 4096
    buf = buf or t.buffer(size)
    basep = basep or t.long1()
    local ret, err = C.getdirentries(getfd(fd), buf, size, basep)
    if ret == -1 then return nil, t.error(err or errno()) end
    return t.dirents(buf, ret)
  end
end

function S.unmount(target, flags)
  return retbool(C.unmount(target, c.MNT[flags]))
end

function S.revoke(path) return retbool(C.revoke(path)) end
function S.chflags(path, flags) return retbool(C.chflags(path, c.CHFLAGS[flags])) end
if C.lchflags then
  function S.lchflags(path, flags) return retbool(C.lchflags(path, c.CHFLAGS[flags])) end
end
function S.fchflags(fd, flags) return retbool(C.fchflags(getfd(fd), c.CHFLAGS[flags])) end
if C.chflagsat then
  function S.chflagsat(dirfd, path, flags, atflag)
    return retbool(C.chflagsat(c.AT_FDCWD[dirfd], path, c.CHFLAGS[flags], c.AT[atflag]))
  end
end

function S.pathconf(path, name) return retnum(C.pathconf(path, c.PC[name])) end
function S.fpathconf(fd, name) return retnum(C.fpathconf(getfd(fd), c.PC[name])) end
if C.lpathconf then
  function S.lpathconf(path, name) return retnum(C.lpathconf(path, c.PC[name])) end
end

function S.kqueue() return retfd(C.kqueue()) end

local sysctltypes = require("syscall." .. abi.os .. ".sysctl")

local function sysctlnametomib(name)
  local origname = name
  name = name:lower()
  local tp = sysctltypes[name]
  if not tp then error("unknown sysctl " .. name) end
  if type(tp) == "table" then tp = tp[2] end
  -- an internal node will be a number or line above will have pulled out table
  -- we do allow calls on internal node to see if that subsystem is there though
  if type(tp) == "number" or type(tp) == "table" then tp = "none" end
  name = split("%.", name)
  local prefix
  local tab
  for i = 1, #name do
    if not prefix then prefix = name[i] else prefix = prefix .. "." .. name[i] end
    local part = sysctltypes[prefix]
    if i == #name then
      if type(part) == "table" then name[i] = part[1]
      elseif type(part) == "number" then name[i] = part
      else
        if tab and tab[name[i]] then name[i] = tab[name[i]] else error("sysctl unknown " .. name[i] .. " in " .. origname) end
      end
    else
      if type(part) == "table" then name[i], tab = part[1], part[2] else name[i] = part end
    end
  end
  return name, tp
end

local function sysctlsort(a, b)
  local a = sysctlnametomib(a)
  local b = sysctlnametomib(b)
  for i = 1, #a do
    if i > #b then return true end
    if a[i] < b[i] then return true end
    if b[i] < a[i] then return false end
  end
  return true
end

local allmeta = {
  __tostring = function(t)
    local names = {}
    for k, v in pairs(t) do names[#names + 1] = k end
    table.sort(names, sysctlsort)
    local tt = {}
    for i, v in pairs(names) do tt[i] = v .. " = " .. tostring(t[v]) end
    return table.concat(tt, '\n')
  end,
}

-- "-a" functionality, well all the ones we know about
-- TODO also use for all under one node
local function allsysctl()
  local all = {}
  for k, v in pairs(sysctltypes) do
    if type(v) == "table" and type(v[2]) == "string" then v = v[2] end
    if type(v) == "string" then
      local res, err = S.sysctl(k)
      if res then all[k] = res end
    end
  end
  return setmetatable(all, allmeta)
end

-- TODO understand return types
function S.sysctl(name, new, old) -- TODO may need to change arguments, note order as should not need to specify old
  if not name then return allsysctl() end
  local tp
  if type(name) == "string" then
    name, tp = sysctlnametomib(name)
  end
  local namelen = #name
  local oldlenp, newlen
  if tp then
    if tp == "string" then
      oldlenp = t.size1(256) -- TODO adapt if too small
      old = t.buffer(oldlenp[0])
    elseif tp == "int" then
      oldlenp = t.size1(s.int)
      old = t.int1()
    elseif tp == "int64" then
      oldlenp = t.size1(s.int64)
      old = t.int64_1()
    elseif tp == "none" then -- TODO not apparently working, maybe just list all children for internal node case
      oldlenp = t.size1(s.int)
      old = t.int1()
    else
      oldlenp = t.size1(s[tp])
      old = t[tp]()
    end
  elseif type(old) == "number" then -- specified length of buffer
    oldlenp = t.size1(old)
    old = t.buffer(old)
  elseif not old then -- default to int
    tp = "int"
    oldlenp = t.size1(s.int)
    old = t.int1()
  else
    oldlenp = t.size1(#old)
  end
  if new then newlen = #new else newlen = 0 end -- TODO set based on known types too
  local name = t.ints(namelen, name)
  local ret, err = C.sysctl(name, namelen, old, oldlenp, new, newlen)
  if ret == -1 then return nil, t.error(err or errno()) end
  if tp then -- we know type of value being returned
    if tp == "string" then return ffi.string(old)
    elseif tp == "int" then return tonumber(old[0])
    elseif tp == "int64" then return old[0]
    elseif tp == "none" then return true
    else return old
    end
    return old
  end
  return old, nil, oldlenp[0] -- not ideal, but add the sysctls you want to sysctl.lua...
end

-- note osx has kevent64 too, different type
function S.kevent(kq, changelist, eventlist, timeout)
  if timeout then timeout = mktype(t.timespec, timeout) end
  local changes, changecount = nil, 0
  if changelist then changes, changecount = changelist.kev, changelist.count end
  if eventlist then
    local ret, err = C.kevent(getfd(kq), changes, changecount, eventlist.kev, eventlist.count, timeout)
    return retiter(ret, err, eventlist.kev)
  end
  return retnum(C.kevent(getfd(kq), changes, changecount, nil, 0, timeout))
end

function S.tcgetattr(fd) return S.ioctl(fd, "TIOCGETA") end
local tcsets = {
  [c.TCSA.NOW]   = "TIOCSETA",
  [c.TCSA.DRAIN] = "TIOCSETAW",
  [c.TCSA.FLUSH] = "TIOCSETAF",
}
function S.tcsetattr(fd, optional_actions, tio)
  -- TODO also implement TIOCSOFT, which needs to make a modified copy of tio
  local inc = c.TCSA[optional_actions]
  return S.ioctl(fd, tcsets[inc], tio)
end
function S.tcsendbreak(fd, duration)
  local ok, err = S.ioctl(fd, "TIOCSBRK")
  if not ok then return nil, err end
  S.nanosleep(0.4) -- BSD just does constant time
  local ok, err = S.ioctl(fd, "TIOCCBRK")
  if not ok then return nil, err end
  return true
end
function S.tcdrain(fd)
  return S.ioctl(fd, "TIOCDRAIN")
end
function S.tcflush(fd, com)
  return S.ioctl(fd, "TIOCFLUSH", c.TCFLUSH[com]) -- while defined as FREAD, FWRITE, values same
end
local posix_vdisable = octal "0377" -- TODO move to constants? check in all BSDs
function S.tcflow(fd, action)
  action = c.TCFLOW[action]
  if action == c.TCFLOW.OOFF then return S.ioctl(fd, "TIOCSTOP") end
  if action == c.TCFLOW.OON then return S.ioctl(fd, "TIOCSTART") end
  if action ~= c.TCFLOW.ION and action ~= c.TCFLOW.IOFF then return nil end
  local term, err = S.tcgetattr(fd)
  if not term then return nil, err end
  local cc
  if action == c.TCFLOW.IOFF then cc = term.VSTOP else cc = term.VSTART end
  if cc ~= posix_vdisable and not S.write(fd, t.uchar1(cc), 1) then return nil end
  return true
end
function S.issetugid() return C.issetugid() end

-- these are not in NetBSD; they are syscalls in FreeBSD, OSX, libs functions in Linux; they could be in main syscall.
if C.shm_open then
  function S.shm_open(pathname, flags, mode)
    if type(pathname) == "string" and pathname:sub(1, 1) ~= "/" then pathname = "/" .. pathname end
    return retfd(C.shm_open(pathname, c.O[flags], c.MODE[mode]))
  end
end
if C.shm_unlink then
  function S.shm_unlink(pathname) return retbool(C.shm_unlink(pathname)) end
end

-- TODO move these to FreeBSD only as apparently NetBSD deprecates the non Linux xattr interfaces
-- although there are no man pages for the Linux ones...
-- doc says behaves like read, write, but as there seem to be limits on attr size and total size
-- seems pointless to not read the whole thing at once

local function extattr_get_helper(fn, ff, attrnamespace, attrname, data, nbytes)
  attrnamespace = c.EXTATTR_NAMESPACE[attrnamespace]
  if data or data == false then
    if data == false then data, nbytes = nil, 0 end
    return retnum(fn(ff, attrnamespace, attrname, data, nbytes or #data))
  end
  local nbytes, err = fn(ff, attrnamespace, attrname, nil, 0)
  nbytes = tonumber(nbytes)
  if nbytes == -1 then return nil, t.error(err or errno()) end
  local data = t.buffer(nbytes)
  local n, err = fn(ff, attrnamespace, attrname, data, nbytes)
  n = tonumber(n)
  if n == -1 then return nil, t.error(err or errno()) end
  return ffi.string(data, n)
end

if C.extattr_get_fd then
  function S.extattr_get_fd(fd, attrnamespace, attrname, data, nbytes)
    return extattr_get_helper(C.extattr_get_fd, getfd(fd), attrnamespace, attrname, data, nbytes)
  end
end

if C.extattr_get_file then
  function S.extattr_get_file(file, attrnamespace, attrname, data, nbytes)
    return extattr_get_helper(C.extattr_get_file, file, attrnamespace, attrname, data, nbytes)
  end
end

if C.extattr_get_link then
  function S.extattr_get_link(file, attrnamespace, attrname, data, nbytes)
    return extattr_get_helper(C.extattr_get_link, file, attrnamespace, attrname, data, nbytes)
  end
end

if C.extattr_set_fd then
   function S.extattr_set_fd(fd, attrnamespace, attrname, data, nbytes)
     local str = data -- do not gc
     if type(data) == "string" then data, nbytes = pt.char(str), #str end
     return retnum(C.extattr_set_fd(getfd(fd), c.EXTATTR_NAMESPACE[attrnamespace], attrname, data, nbytes or #data))
   end
end

if C.extattr_delete_fd then
  function S.extattr_delete_fd(fd, attrnamespace, attrname)
    return retbool(C.extattr_delete_fd(getfd(fd), c.EXTATTR_NAMESPACE[attrnamespace], attrname))
  end
end

if C.extattr_set_file then
   function S.extattr_set_file(file, attrnamespace, attrname, data, nbytes)
     local str = data -- do not gc
     if type(data) == "string" then data, nbytes = pt.char(str), #str end
     return retnum(C.extattr_set_file(file, c.EXTATTR_NAMESPACE[attrnamespace], attrname, data, nbytes or #data))
   end
end

if C.extattr_delete_file then
  function S.extattr_delete_file(file, attrnamespace, attrname)
    return retbool(C.extattr_delete_file(file, c.EXTATTR_NAMESPACE[attrnamespace], attrname))
  end
end

if C.extattr_set_link then
   function S.extattr_set_link(file, attrnamespace, attrname, data, nbytes)
     local str = data -- do not gc
     if type(data) == "string" then data, nbytes = pt.char(str), #str end
     return retnum(C.extattr_set_link(file, c.EXTATTR_NAMESPACE[attrnamespace], attrname, data, nbytes or #data))
   end
end

if C.extattr_delete_link then
  function S.extattr_delete_link(file, attrnamespace, attrname)
    return retbool(C.extattr_delete_link(file, c.EXTATTR_NAMESPACE[attrnamespace], attrname))
  end
end

local function parse_extattr(buf, n)
  local tab, i = {}, 0
  while n > 0 do
    local len = buf[i]
    tab[#tab + 1] = ffi.string(buf + i + 1, len)
    i, n = i + (len + 1), n - (len + 1)
  end
  return tab
end

local function extattr_list_helper(fn, ff, attrnamespace, data, nbytes)
  attrnamespace = c.EXTATTR_NAMESPACE[attrnamespace]
  if data == false then return retnum(fn(ff, attrnamespace, nil, 0)) end
  if data then
    return retnum(fn(ff, attrnamespace, data, nbytes or #data)) -- TODO should we parse?
  end
  local nbytes, err = fn(ff, attrnamespace, nil, 0)
  nbytes = tonumber(nbytes)
  if nbytes == -1 then return nil, t.error(err or errno()) end
  local data = t.buffer(nbytes)
  local n, err = fn(ff, attrnamespace, data, nbytes)
  n = tonumber(n)
  if n == -1 then return nil, t.error(err or errno()) end
  return parse_extattr(data, n)
end

if C.extattr_list_fd then
  function S.extattr_list_fd(fd, attrnamespace, data, nbytes)
    return extattr_list_helper(C.extattr_list_fd, getfd(fd), attrnamespace, data, nbytes)
  end
end

if C.extattr_list_file then
  function S.extattr_list_file(file, attrnamespace, data, nbytes)
    return extattr_list_helper(C.extattr_list_file, file, attrnamespace, data, nbytes)
  end
end

if C.extattr_list_link then
  function S.extattr_list_link(file, attrnamespace, data, nbytes)
    return extattr_list_helper(C.extattr_list_link, file, attrnamespace, data, nbytes)
  end
end

return S

end