exo_sw_dissectors/Dissector/tc_tm_protocols.lua

-- Define the protocol
TC_TM_PROTOCOL = Proto("tc_tm", "TC_TM")

local f_sof1 = ProtoField.uint8("TC_TM_PROTOCOL.sof1", "SOF1", base.HEX)
local f_sof2 = ProtoField.uint8("TC_TM_PROTOCOL.sof2", "SOF2", base.HEX)
local f_tm_ctrl = ProtoField.uint8("TC_TM_PROTOCOL.tm_ctrl", "TM Ctrl", base.HEX)
local f_GS_Id = ProtoField.uint8("TC_TM_PROTOCOL.GS_Id", "GS Id", base.HEX)
local f_timestamp = ProtoField.string("TC_TM_PROTOCOL.timestamp", "Timestamp", base.NONE)
local f_ist = ProtoField.string("TC_TM_PROTOCOL.timestamp_ist", "IST TIME ", base.NONE)
local f_pst = ProtoField.string("TC_TM_PROTOCOL.timestamp_pst", "PST TIME", base.NONE)
local f_est = ProtoField.string("TC_TM_PROTOCOL.timestamp_est", "EST TIME", base.NONE)
local f_mt = ProtoField.string("TC_TM_PROTOCOL.timestamp", "MST TIME", base.NONE)
local f_sequence_no = ProtoField.uint16("TC_TM_PROTOCOL.sequence_no", "Sequence No", base.DEC)
local f_sat_id = ProtoField.uint16("TC_TM_PROTOCOL.sat_id", "SAT Id", base.DEC)
local f_qos = ProtoField.uint8("TC_TM_PROTOCOL.qos", "QoS", base.DEC)
local f_sa_id = ProtoField.uint16("TC_TM_PROTOCOL.sa_id", "SA Id", base.DEC)
local f_da_id = ProtoField.uint16("TC_TM_PROTOCOL.da_id", "DA Id", base.DEC)
local f_rm_id = ProtoField.uint8("TC_TM_PROTOCOL.rm_id", "RM Id", base.DEC)
local f_tm_id = ProtoField.uint16("TC_TM_PROTOCOL.tm_id", "TM Id", base.DEC)
local f_co_id = ProtoField.uint16("TC_TM_PROTOCOL.co_id", "Co Id", base.DEC)
local f_tm_len = ProtoField.uint16("TC_TM_PROTOCOL.tm_len", "TM Len", base.DEC)
local f_tm_data = ProtoField.uint8("TC_TM_PROTOCOL.tm_data", "TM Data", base.DEC)
local f_ext_header_len = ProtoField.uint8("TC_TM_PROTOCOL.ext_header_len", "Ext Header Len", base.DEC)
local f_ext_header_data = ProtoField.uint8("TC_TM_PROTOCOL.ext_header_data", "Ext Header Data", base.DEC)
local f_crc = ProtoField.uint8("TC_TM_PROTOCOL.crc", "CRC", base.DEC)
local f_c_mac = ProtoField.uint8("TC_TM_PROTOCOL.c_mac", "C MAC", base.DEC)
local f_eof1 = ProtoField.uint8("TC_TM_PROTOCOL.eof1", "EOF", base.HEX)
local f_tc_id = ProtoField.uint16("TC_TM_PROTOCOL.tc_id", "TC Id", base.DEC)
local f_tc_len = ProtoField.uint16("TC_TM_PROTOCOL.tc_len", "TC Len", base.DEC)
local f_tc_data = ProtoField.uint32("TC_TM_PROTOCOL.tc_data", "TC Data", base.DEC)

-- Add the fields to the protocol
TC_TM_PROTOCOL.fields = {
    f_sof1, f_sof2, f_tm_ctrl,f_GS_Id, f_timestamp, f_sequence_no, f_sat_id, f_ist, f_pst, f_est, f_mt,
    f_qos, f_sa_id, f_da_id, f_rm_id, f_tm_id, f_co_id, f_tm_len, f_tm_data,
    f_ext_header_len, f_ext_header_data, f_crc, f_c_mac, f_eof1,f_tc_id ,f_tc_len ,f_tc_data 
}

------------------------------------------------------------------------------------------------------------------------------------


function TC_dissector(buffer, pinfo, tree)
--Set the protocol coloumn name in wireshark
   local subtree = tree:add(TC_TM_PROTOCOL, buffer(), "TELECOMMAND")
    
    -- Dissect SOF1 and SOF2
    local offset = 0
    
    for i = 0,1000 do
      local data = buffer(i,1):le_uint()
      if data == 0xa5 then
        offset = i
        break
      end
    end
      
    subtree:add(f_sof1 , buffer(offset, 1))
    offset = offset + 1
    
    subtree:add(f_sof2, buffer(offset, 1))
    offset = offset + 1
    
    -- Dissect TC Control byte (TC_Ctrl)
    local tc_ctrl = buffer(offset, 1):le_uint()  -- Get the value of TC Ctrl byte
    subtree:add(f_tm_ctrl , tc_ctrl)
    offset = offset + 1
    
    -- Dissect Timestamp (4 bytes)
    if buffer:len() >= offset + 4 then
        local timestamp = buffer(offset, 4):le_uint()
        local utc_time = os.date("!%Y-%m-%d %H:%M:%S", timestamp)
        subtree:add(f_timestamp, timestamp.." ".."("..utc_time..")" )
        
        local time = timestamp + 19800
        local ist_time = os.date("!%Y-%m-%d %H:%M:%S", time)
        subtree:add(f_ist, ist_time)
        
        time = timestamp - 28800
        local pst_time = os.date("!%Y-%m-%d %H:%M:%S", time) 
        subtree:add(f_pst, pst_time)
        
        time = timestamp - 18000
        local est_time = os.date("!%Y-%m-%d %H:%M:%S", time) 
        subtree:add(f_est, est_time)
        
        time = timestamp - 25200
        local mt_time = os.date("!%Y-%m-%d %H:%M:%S", time) 
        subtree:add(f_mt, mt_time)
        
        offset = offset + 4
    else
        subtree:add(f_timestamp, "Invalid data (timestamp)")
    end
    
    -- Dissect Sequence No (2 bytes)
    if buffer:len() >= offset + 2 then
        local sequence = buffer(offset, 2):le_uint()
        subtree:add(f_sequence_no, sequence)
        offset = offset + 2
    else
       subtree:add(f_sequence_no, "Invalid data (sequence number)")
    end
    
    -- Dissect SAT_Id (1 byte)
    if buffer:len() >= offset + 1 then
        local sat_id = buffer(offset, 1):uint()  -- Get SAT Id (1st byte)
            --offset = offset + 1
            
            if bit.band(sat_id, 0x80) == 0x80 then     --if 7th bit is set and 
                if buffer:len() >= offset + 1 then
                    local second = buffer(offset, 2):le_uint()
                    
                    if bit.band(second, 0x8000) == 0x0000 then    --and 15th bit is set then unset 15th bit 
                    sat_id = buffer(offset, 2):le_uint()
                    sat_id = bit.band(sat_id, 0xFF7F)
                    offset = offset + 1
                    
                    else
                    sat_id = buffer(offset, 2):le_uint()
                    sat_id = bit.band(sat_id, 0x7FFF)  -- and 15th bit is unset then unset the 7th bit
                    offset = offset + 1
                    end
                end
            end
            subtree:add(f_sat_id, sat_id)
            offset = offset + 1
    end
    
    -- Dissect GS_Id (1 byte)
    if buffer:len() >= offset + 1 then
        local gs_id = buffer(offset, 1):uint()  -- Get SAT Id (1st byte)
            --offset = offset + 1
            
            if bit.band(gs_id, 0x80) == 0x80 then
                if buffer:len() >= offset + 1 then
                    local second = buffer(offset, 2):le_uint()
                    
                    if bit.band(second, 0x8000) == 0x0000 then
                    gs_id = buffer(offset, 2):le_uint()
                    gs_id = bit.band(gs_id, 0xFF7F)
                    offset = offset + 1
                    
                    else
                    gs_id = buffer(offset, 2):le_uint()
                    gs_id = bit.band(gs_id, 0x7FFF)
                    offset = offset + 1
                    end
                end
            end
            subtree:add(f_GS_Id, gs_id)
            offset = offset + 1
    end
    
    -- Dissect QoS (1 byte)
    if buffer:len() >= offset + 1 then
        subtree:add(f_qos, buffer(offset, 1))
        offset = offset + 1
    end
    
    -- Dissect SA_Id (Source Application ID) and DA_Id (Destination Application ID)
    if buffer:len() >= offset + 1 then
        local sa_id = buffer(offset, 1):uint()  -- Get source Application Id (1st byte)
            --offset = offset + 1
            
            if bit.band(sa_id, 0x80) == 0x80 then
                if buffer:len() >= offset + 1 then
                   local second = buffer(offset, 2):le_uint()
                    
                    if bit.band(second, 0x8000) == 0x0000 then
                    sa_id = buffer(offset, 2):le_uint()
                    sa_id = bit.band(sa_id, 0xFF7F)
                    offset = offset + 1
                    
                    else
                    sa_id = buffer(offset, 2):le_uint()
                    sa_id = bit.band(sa_id, 0x7FFF)
                    offset = offset + 1
                    end
                end
            end
            subtree:add(f_sa_id, sa_id)
            offset = offset + 1
     end
        
        if buffer:len() >= offset + 1 then
            --subtree:add(f_DA_Id, buffer(offset, 1))
            local da_id = buffer(offset, 1):le_uint()  -- Get Destination Application Id (1st byte)
            --offset = offset + 1
            
            if bit.band(da_id, 0x80) == 0x80 then
                if buffer:len() >= offset + 1 then
                        
 		local second = buffer(offset, 2):le_uint()
                    
                    if bit.band(second, 0x8000) == 0x0000 then
                    da_id = buffer(offset, 2):le_uint()
                    da_id = bit.band(da_id, 0xFF7F)
                    offset = offset + 1
                    
                    else
                    da_id = buffer(offset, 2):le_uint()
                    da_id = bit.band(da_id, 0x7FFF)
                    offset = offset + 1
                    end
                end
            end
            subtree:add(f_da_id, da_id)
            offset = offset + 1
        end
    
    -- Dissect RM_Id (1 byte)
    if buffer:len() >= offset + 1 then
        subtree:add(f_rm_id, buffer(offset, 1))
        offset = offset + 1
    end
    
    -- Dissect TC_Id (2 bytes)
   -- Dissect TC_Id (2 bytes)
	local info_display
 
   local tc_id = buffer(offset, 1):le_uint() -- Read 1 byte for tc_id
   
   if tc_id == 100 or tc_id == 102 or tc_id == 103 then
   pinfo.cols.protocol = "FTM(UL)"
   elseif tc_id == 105 then
   pinfo.cols.protocol = "FTM(DL)"
   else
   pinfo.cols.protocol = "TELECOMMAND"
   end
   
   if buffer:len() >= offset + 2 then  -- Ensure enough data is available to read 2 bytes

    -- Check if the 7th bit (0x80) is set in tc_id
    if bit.band(tc_id, 0x80) == 0x80 then
        if buffer:len() >= offset + 2 then  -- Ensure enough data for the next 2 bytes
           
                    
 		local second = buffer(offset, 2):le_uint()
                    
                    if bit.band(second, 0x8000) == 0x0000 then
                    tc_id = buffer(offset, 2):le_uint()
                    tc_id = bit.band(tc_id, 0xFF7F)
                    offset = offset + 1
                    
                    else
                    tc_id = buffer(offset, 2):le_uint()
                    tc_id = bit.band(tc_id, 0x7FFF)
                    offset = offset + 1
                    end
        end
    end

    -- Add tc_id to the subtree (display in dissection tree)
    subtree:add(f_tc_id, tc_id)
    
    -- Move the offset forward by 1 (since we initially read 1 byte)
    offset = offset + 1
end


    -- Dissect TC_Len (2 bytes)
    local tc_len = 0  -- Declare tc_len as a local variable here
    if buffer:len() >= offset + 2 then
        tc_len = buffer(offset, 2):le_uint()
        subtree:add(f_tc_len, tc_len)
        offset = offset + 2
    end
    
    -- Dissect TC_Data (variable length)
    --local subtree2 = subtree:add(TC_TM_PROTOCOL, buffer(), TC_DATA())
    local data
    if buffer:len() >= offset + tc_len then
          if  tc_len == 0 then
              subtree:add("TC DATA : NIL")
          else
              if tc_id == 621 then
                 	require("hm_dissector")
                	data = HM_TC_dissector(buffer, pinfo, tree, TC_TM_PROTOCOL, offset)
                	offset = offset + tc_len  
		          elseif tc_id == 100 then
                	require("ftci_dissector")
			            ftci_dissector(buffer, pinfo, tree, TC_TM_PROTOCOL, offset)
                	offset = offset + tc_len 
		          elseif tc_id == 103 then
                	require("ftfci_dissector")
			            ftfci_dissector(buffer, pinfo, tree, TC_TM_PROTOCOL, offset)
                	offset = offset + tc_len 
		          elseif tc_id == 102 then
                 	require("ftds_dissector")
                 	ftds_dissector(buffer, pinfo, tree, TC_TM_PROTOCOL, offset)
                 	offset = offset + tc_len
		          elseif tc_id == 105 then
                 	require("ftsr_dissector")
          		    ftsr_dissector(buffer, pinfo, tree, TC_TM_PROTOCOL, offset)
                 	offset = offset + tc_len
              elseif tc_id == 202 then
                  require("eps_wr_stored_param")
                  eps_tc_wr_stored_param_dissector(buffer, pinfo, tree, TC_TM_PROTOCOL, offset)
                  offset = offset + tc_len
              elseif tc_id == 211 then
                  require("tc_eps_set_cntrl_chnl_state")
                  tc_eps_set_cntrl_chnl_state(buffer, pinfo, tree, TC_TM_PROTOCOL, offset)
                  offset = offset + tc_len
                 else
	              for i=0,tc_len - 1 do
        	      subtree:add(f_tc_data, buffer(offset, 1))
      	        	offset = offset + 1
             		end
                 end
	end
    end
    

    -- Check if we can dissect Ext_Header_Len
    if bit.band(tc_ctrl, 0x80) == 0x80 and buffer:len() >= offset + 1 then
        subtree:add(f_ext_header_len, buffer(offset, 1))
        local ext_header_len = buffer(offset, 1):uint()
        offset = offset + 1

        if buffer:len() >= offset + ext_header_len then
	    for i=1,ext_header_len do
            	subtree:add(f_ext_header_data, buffer(offset, 1))
            	offset = offset + 1
		end
        end
   end
    
    -- Dissect CRC (1 byte)
    if buffer:len() >= offset + 1 then
        subtree:add(f_crc, buffer(offset, 1))
        offset = offset + 1
    end
    
    -- Dissect C-MAC/H-MAC (if TC Ctrl bit 4 is set)
    if bit.band(tc_ctrl, 0x10) == 0x10 and buffer:len() >= offset + 32 then
	for i=1,32 do
        	subtree:add(f_c_mac, buffer(offset, 1))
        	offset = offset + 1
	end
    end
    
    -- Dissect EOF (1 byte)
    if buffer:len() >= offset + 1 then
        subtree:add(f_eof1, buffer(offset, 1))
    end
    local string
    
    if tc_id == 621 then
    
    local switch = {
    [9] = function() return "EPS" end, 
    [22] = function() return "ADCS" end,
    [14] = function() return "SBAND" end,
    [15] = function() return "UHF" end,
    [42] = function() return "SENSOR" end,
    [27] = function() return "OBC" end
    }
    string = (switch[data] or function() return "All Module" end)()
    info_display= {buffer(11, 2):le_uint(),buffer(7, 4):le_uint() ,tc_id, string} --- for info display in wireshark
    pinfo.cols.info ="seq_no = " ..info_display[1] ..", TS = " ..info_display[2]..", TC_ID = "..info_display[3]..", Module = " ..info_display[4] -- for info display in wireshark
   
   elseif tc_id == 100 then
    
    string = "FTCI FRAME"
    info_display= {buffer(11, 2):le_uint(),buffer(7, 4):le_uint() ,tc_id, string} --- for info display in wireshark
    pinfo.cols.info ="seq_no = " ..info_display[1] ..", TS = " ..info_display[2]..", TC_ID = "..info_display[3]..", " ..info_display[4] -- for info display in wireshark
   
    elseif tc_id == 105 then
    
    string = "FTSR FRAME"
    info_display= {buffer(11, 2):le_uint(),buffer(7, 4):le_uint() ,tc_id, string} --- for info display in wireshark
    pinfo.cols.info ="seq_no = " ..info_display[1] ..", TS = " ..info_display[2]..", TC_ID = "..info_display[3]..", " ..info_display[4] -- for info display in wireshark
    
    
    elseif tc_id == 102 then
    
    string = "FTDS FRAME"
    info_display= {buffer(11, 2):le_uint(),buffer(7, 4):le_uint() ,tc_id, string} --- for info display in wireshark
    pinfo.cols.info ="seq_no = " ..info_display[1] ..", TS = " ..info_display[2]..", TC_ID = "..info_display[3]..", " ..info_display[4] -- for info display in wireshark
    
  	 elseif tc_id == 103 then
    
    string = "FTFCI FRAME"
    info_display= {buffer(11, 2):le_uint(),buffer(7, 4):le_uint() ,tc_id, string} --- for info display in wireshark
    pinfo.cols.info ="seq_no = " ..info_display[1] ..", TS = " ..info_display[2]..", TC_ID = "..info_display[3]..", " ..info_display[4] -- for info display in wireshark
     	
  
    else            
    
    info_display= {buffer(11, 2):le_uint(),buffer(7, 4):le_uint() ,tc_id} --- for info display in wireshark

    
    pinfo.cols.info ="seq_no = " ..info_display[1] ..", TS = " ..info_display[2]..", TC_ID = "..info_display[3] -- for info display in wireshark
    end
end

-----------------------------------------------------------------------------------------------------------------------------------
function TM_dissector(buffer, pinfo, tree)  -- OBC to GS

	local subtree = tree:add(TC_TM_PROTOCOL, buffer(), "TELEMETRY")

    -- Extract the fields in order as defined in the structure
    
    local add
    
    for i = 0,1000 do
      local data = buffer(i,1):le_uint()
      if data == 0xa5 then
        add = i
        break
      end
    end
        
    subtree:add(f_sof1, buffer(add, 1):le_uint())  -- SOF1 in HEX
    add = add + 1
    
    subtree:add(f_sof2, buffer(add, 1):le_uint())  -- SOF2 in HEX
    add = add + 1
    
    local tm_ctrl = buffer(add, 1):le_uint()
    subtree:add(f_tm_ctrl, buffer(add, 1):le_uint())  -- TM Ctrl in HEX
    add = add + 1
    -- Dissect timestamp
    local timestamp = buffer(add, 4):le_uint()
    local utc_time = os.date("!%Y-%m-%d %H:%M:%S", timestamp)
    subtree:add(f_timestamp, timestamp.." ".."("..utc_time..")" )
    
    local time = timestamp + 19800
        local ist_time = os.date("!%Y-%m-%d %H:%M:%S", time)
        subtree:add(f_ist, ist_time)
        
        time = timestamp - 28800
        local pst_time = os.date("!%Y-%m-%d %H:%M:%S", time) 
        subtree:add(f_pst, pst_time)
        
        time = timestamp - 18000
        local est_time = os.date("!%Y-%m-%d %H:%M:%S", time) 
        subtree:add(f_est, est_time)
        
        time = timestamp - 25200
        local mt_time = os.date("!%Y-%m-%d %H:%M:%S", time) 
        subtree:add(f_mt, mt_time)
        
    add = add + 4
   
    subtree:add(f_sequence_no, buffer(add, 2):le_uint())  -- Sequence No in HEX
    add = add + 2
       
-- My logic for SAT Id
    local magic = buffer(add, 1):le_uint()

    if bit.band(magic, 0x80) == 0 then
        subtree:add(f_sat_id, buffer(add, 1):le_uint())  -- SAT Id in HEX
	add=add+1
    else
	
	magic=buffer(add, 2):le_uint()
	local dummy=magic & 0x8000    --to check 7th byte is 1
	if dummy == 0 then
		magic = magic & 0xff7f -- if 15th bit is 0 set 7th bit 0
	else 
		magic = magic & 0x7fff -- if 15 bit is 1 set 15th bit to 0
	end
        subtree:add(f_sat_id, magic)  -- SAT Id in HEX
	add=add+2
	
    end

    -- QoS in HEX
    subtree:add(f_qos, buffer(add, 1):le_uint())
    add=add+1

    -- My logic for SA Id
    magic = buffer(add, 1):le_uint()
    if bit.band(magic, 0x80) == 0 then
        subtree:add(f_sa_id, buffer(add, 1):le_uint())  -- SA Id in HEX
	add=add+1
    else
	magic=buffer(add, 2):le_uint()
	local dummy=magic & 0x8000
	if dummy == 0 then
		magic = magic & 0xff7f
	else 
		magic = magic & 0x7fff
	end 
        subtree:add(f_sa_id,magic)  -- SA Id in HEX
	add=add+2
    end

    -- My logic for DA Id
    magic = buffer(add, 1):uint()
    if bit.band(magic, 0x80) == 0 then
        subtree:add(f_da_id, buffer(add, 1):le_uint())  -- DA Id in HEX
	add=add+1
    else
	magic=buffer(add, 2):le_uint()
	local dummy=magic & 0x8000
	if dummy == 0 then
		magic = magic & 0xff7f
	else 
		magic = magic & 0x7fff
	end
        subtree:add(f_da_id, magic)  -- DA Id in HEX
	add=add+2
    end

    -- RM Id in HEX
    subtree:add(f_rm_id, buffer(add, 1):le_uint())
    add=add+1

    -- My logic for TM Id
    local info_display    -- for display in wireshark
    local tm_id
    
    magic = buffer(add, 1):uint()
    if bit.band(magic, 0x80) == 0 then
        subtree:add(f_tm_id, buffer(add, 1):le_uint())  -- TM Id in HEX
	 info_display= {buffer(11, 2):le_uint(),buffer(7, 4):le_uint() ,buffer(add, 1):le_uint()} --- for info display in wireshark
	add=add+1
    else
	magic=buffer(add, 2):le_uint()
	local dummy=magic & 0x8000
	if dummy == 0 then
		magic = magic & 0xff7f
	else 
		magic = magic & 0x7fff
	end
        subtree:add(f_tm_id, magic)  -- TM Id in HEX
	      add=add+2
    end

    tm_id = magic
    
   if tm_id == 104 or tm_id == 106 or tm_id == 107 then
   pinfo.cols.protocol = "FTM(DL)"
   elseif tm_id == 101 then
   pinfo.cols.protocol = "FTM(UL)"
   else
   pinfo.cols.protocol = "TELEMETRY"
   end
    
    -- Co Id in HEX
    subtree:add(f_co_id, buffer(add, 2):le_uint())
    add=add+2
    
    -- TM Len in HEX
    local tm_len
    
    magic = buffer(add, 2):le_uint()
    tm_len = magic
    subtree:add(f_tm_len, buffer(add, 2):le_uint())
    add=add+2

    --  logic for TM Data
  local array
	--local subtree2 = subtree:add(TC_TM_PROTOCOL, buffer(), "TM_DATA")
 
   -- Dissect TM_Data (variable length)
	
	

      if tm_id == 621 or  tm_id == 815 or  tm_id == 104 or  tm_id == 107 or  tm_id == 101 or  tm_id == 106  or tm_id == 200 or tm_id == 201 or tm_id == 202 or 
      tm_id == 129 or tm_id == 241 or tm_id == 130 or tm_id == 133 or tm_id == 134 or tm_id == 135 or tm_id == 137 or tm_id == 195 or tm_id == 196 or 
      tm_id == 184 or tm_id == 855 or tm_id == 857 or tm_id == 800 or tm_id == 819 or tm_id == 823 or tm_id == 398 or tm_id == 413 or tm_id == 461 or
      tm_id == 463 or tm_id == 464 or tm_id == 468 or tm_id == 474 or tm_id == 475 or tm_id == 412 or tm_id == 253 or tm_id == 411 or tm_id == 211 or
      tm_id == 212 then
      			if tm_id == 621  then
      				require("hm_dissector")
        			array = HM_TM_dissector(buffer, pinfo, tree, TC_TM_PROTOCOL, add, tm_len)
        			add = add + tm_len

 			      elseif tm_id == 815  then
 				      require("bcon")
        			bcon_dissector(buffer, pinfo, tree, TC_TM_PROTOCOL, add, tm_len)
        			add = add + tm_len

			       elseif tm_id == 104 then
       			      require("ftci_dissector")
					        ftci_dissector(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
          			  add = add + tm_len 
            elseif tm_id == 107 then
       			      require("ftfci_dissector")
					        ftfci_dissector(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
          			  add = add + tm_len
		        elseif tm_id == 101 then 
      				require("ftsr_dissector")
      				ftsr_dissector(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
      				add = add + tm_len
				    elseif tm_id == 106 then 
			        require("ftds_dissector")
     			    ftds_dissector(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
     				   add = add + tm_len
            elseif tm_id == 200 then
              require("eps_get_live_param");
              eps_get_live_param_dissector(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
              add = add + tm_len
            elseif tm_id == 201 then
              require("eps_rd_stored_param");
              eps_rd_stored_param_dissector(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
              add = add + tm_len
            elseif tm_id == 202 then
              require("eps_tm_wr_stored_param");
              eps_tm_wr_stored_param_dissector(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
              add = add + tm_len
            elseif tm_id == 129 then
              require("tm_get_adcs_state");
              tm_get_adcs_state(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
              add = add + tm_len
            elseif tm_id == 253 then
              require("tm_adcs_state_cfg");
              tm_adcs_state_cfg(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
              add = add + tm_len
            elseif tm_id == 241 then
              require("tm_adcs_get_est_attitude_angl");
              tm_get_adcs_estimated_angle(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
              add = add + tm_len
	          elseif tm_id == 130 then 
	            require("tm_get_adcs_tle");
	            tm_get_adcs_tle(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
	            add = add + tm_len
            elseif tm_id == 133 then 
              require("tm_get_adcs_mag_field_vector");
	            tm_get_adcs_mag_field_vector(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
	            add = add + tm_len
            elseif tm_id == 134 then 
              require("tm_get_adcs_css_vector");
	            tm_get_adcs_css_vector(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
	            add = add + tm_len
            elseif tm_id == 135 then 
	            require("tm_get_adcs_fss_vector");
	            tm_get_adcs_fss_vector(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
	            add = add + tm_len
            elseif tm_id == 137 then 
	            require("tm_get_adcs_sensor_vector");
	            tm_get_adcs_sensor_vector(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
	            add = add + tm_len
            elseif tm_id == 195 then 
	            require("tm_get_adcs_commanded_wheel_speed");
	            tm_get_command_wheel_speed(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
	            add = add + tm_len
            elseif tm_id == 196 then 
	            require("tm_get_adcs_rw_speed_measure");
	            tm_get_adcs_rw_speed_measure(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
	            add = add + tm_len
            elseif tm_id == 184 then 
	            require("tm_get_adcs_est_rate");
	            tm_get_adcs_est_rate(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
	            add = add + tm_len
            elseif tm_id == 855 then 
	            require("tm_get_sdr_tmr_cfg");
	            tm_get_sdr_tmr_cfg(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
	            add = add + tm_len
            elseif tm_id == 857 then 
	            require("tm_get_sdr_rssi_cfg");
	            tm_get_sdr_rssi_cfg(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
	            add = add + tm_len
            elseif tm_id == 800 then 
	            require("tm_comms_uhf_get_tm_info");
	            tm_comms_uhf_get_tm_info(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
	            add = add + tm_len
            elseif tm_id == 819 then 
	            require("tm_comms_uhf_get_tm_store");
	            tm_comms_uhf_get_tm_store(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
	            add = add + tm_len
            elseif tm_id == 823 then 
	            require("tm_comms_uhf_dbg_cb");
	            tm_comms_uhf_dbg_cb(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
	            add = add + tm_len
            elseif tm_id == 398 then 
	            require("tm_get_comms_tm_info");
	            tm_get_comms_tm_info(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
	            add = add + tm_len
            elseif tm_id == 413 then 
	            require("tm_sband_get_tm_store");
	            tm_sband_get_tm_store(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
	            add = add + tm_len
            elseif tm_id == 461 then 
	            require("tm_get_sband_version");
	            tm_get_sband_version(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
	            add = add + tm_len
            elseif tm_id == 463 then 
	            require("tm_sband_get_device_conf");
	            tm_sband_get_device_conf(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
	            add = add + tm_len
            elseif tm_id == 464 then 
	            require("tm_sband_get_feature_select");
	            tm_sband_get_feature_select(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
	            add = add + tm_len
            elseif tm_id == 468 then 
	            require("tm_sband_get_product_key");
	            tm_sband_get_product_key(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
	            add = add + tm_len
            elseif tm_id == 474 then 
	            require("tm_get_sband_dbg_cb");
	            tm_get_sband_dbg_cb(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
	            add = add + tm_len
            elseif tm_id == 475 then 
	            require("tm_get_sband_tx_rx_on_ts");
	            tm_get_sband_tx_rx_on_ts(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
	            add = add + tm_len
            elseif tm_id == 412 then 
	            require("tm_sband_get_tm_all");
	            tm_sband_get_tm_all(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
	            add = add + tm_len
            elseif tm_id == 411 then 
	            require("tm_comms_beacon_tx");
	            tm_comms_beacon_tx(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
	            add = add + tm_len
            elseif tm_id == 211 then 
	            require("tm_eps_set_cntrl_chnl_state");
	            tm_eps_set_cntrl_chnl_state(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
	            add = add + tm_len
            elseif tm_id == 212 then 
	            require("tm_get_eps_dev_hw_sts");
	            tm_get_eps_dev_hw_sts(buffer, pinfo, tree, TC_TM_PROTOCOL, add)
	            add = add + tm_len


	end

   
      else
        for i=0,magic-1 do
	        subtree:add(f_tm_data, buffer(add, 1):le_uint())
	        add=add+1
        end
      end
    
      
    -- Ext Header Len in HEX
    if bit.band(tm_ctrl, 0x80) == 0x80   then
    	magic=  buffer(add, 1):uint()
    	subtree:add(f_ext_header_len, buffer(add, 1):uint())
    	add=add+1

    --  logic for Ext Header Data
    	for i=0,magic-1 do
	subtree:add(f_ext_header_data, buffer(add, 1):uint())  -- Ext Header Data in HEX
	add=add+1
	end
    end
    -- CRC in HEX
    subtree:add(f_crc, buffer(add, 1):le_uint())
	add=add+1

    -- C MAC in HEX
	--magic = buffer(, 1):le_uint() -- tm control
    if bit.band(tm_ctrl, 0x10) == 0x10   then
	for i=1,32 do
    		subtree:add(f_c_mac, buffer(add, 1):uint())
		add=add+1    
 	end   
    end
    -- EOF1 in HEX
    subtree:add(f_eof1, buffer(add, 1):uint())
    
    local string
    if tm_id == 621 then
    
    	local switch = {
    	[0] = function() return "EPS" end,
    	[1] = function() return "ADCS" end,
    	[2] = function() return "SBAND" end,
    	[3] = function() return "UHF" end,
    	[4] = function() return "SENSOR" end,
    	[5] = function() return "OBC" end,
    	[6] = function() return "ERROR HANDLER" end
    	}
    	string = (switch[array[1]] or function() return "All Module" end)()
    
    
    
    	info_display= {buffer(11, 2):le_uint(),buffer(7, 4):le_uint() ,tm_id, string, array[2], array[3]} --- for info display in wireshark

	 
	pinfo.cols.info ="seq_no = " ..info_display[1]..", TS = " ..info_display[2]..", TM ID = "..info_display[3]..", Module = "..info_display[4]..", Queue id = "..info_display[5]..", Number of instance = "..info_display[6] -- for info display in wireshark
 
 elseif tm_id == 104 then
    
    string = "FTCI FRAME"
    info_display= {buffer(11, 2):le_uint(),buffer(7, 4):le_uint() ,tm_id, string} --- for info display in wireshark
    pinfo.cols.info ="seq_no = " ..info_display[1] ..", TS = " ..info_display[2]..", TM_ID = "..info_display[3]..", " ..info_display[4] -- for info display in wireshark
   
    elseif tm_id == 101 then
    
    string = "FTSR FRAME"
    info_display= {buffer(11, 2):le_uint(),buffer(7, 4):le_uint() ,tm_id, string} --- for info display in wireshark
    pinfo.cols.info ="seq_no = " ..info_display[1] ..", TS = " ..info_display[2]..", TM_ID = "..info_display[3]..", " ..info_display[4] --for info display in wireshark
    
    
    elseif tm_id == 106 then
    
    string = "FTDS FRAME"
    info_display= {buffer(11, 2):le_uint(),buffer(7, 4):le_uint() ,tm_id, string} --- for info display in wireshark
    pinfo.cols.info ="seq_no = " ..info_display[1] ..", TS = " ..info_display[2]..", TM_ID = "..info_display[3]..", " ..info_display[4] -- for info display in wireshark
    
  	 elseif tm_id == 107 then
    
    string = "FTFCI FRAME"
    info_display= {buffer(11, 2):le_uint(),buffer(7, 4):le_uint() ,tm_id, string} --- for info display in wireshark
    pinfo.cols.info ="seq_no = " ..info_display[1] ..", TS = " ..info_display[2]..", TM_ID = "..info_display[3]..", " ..info_display[4] -- for info display in wireshark
    
    elseif tm_id == 815 then
   string = "BEACON"
    info_display= {buffer(11, 2):le_uint(),buffer(7, 4):le_uint() ,tm_id, string} --- for info display in wireshark
    pinfo.cols.info ="seq_no = " ..info_display[1] ..", TS = " ..info_display[2]..", TM_ID = "..info_display[3]..", " ..info_display[4] -- for info display in wireshark
 
    else
        info_display= {buffer(11, 2):le_uint(),buffer(7, 4):le_uint() ,tm_id} --- for info display in wireshark
    
	 
	pinfo.cols.info ="seq_no = " ..info_display[1]..", TS = " ..info_display[2]..", TM ID = "..info_display[3] -- for info display in wireshark
    end
    -- Check if the buffer contains enough data for the expected total length
   --if buffer:len() < 38 + buffer(21, 2):uint() then
     --   subtree:add_expert_info(PI_MALFORMED, PI_WARN, "Incomplete data")
    --end
end
-- Register the dissector for udp port 


-------------------------------------------------------------------------------------------------------------------------------
-- Dissector function
function TC_TM_PROTOCOL.dissector(buffer, pinfo, tree)
	-- Register protocol in preferences (add this part)
	--my_udp_protocol:register_preference()

    pinfo.cols.protocol = "TC_TM"

  local offset1
    
    for i = 0,1000 do
      local data = buffer(i,1):le_uint()
      if data == 0xa5 then
        offset1 = i
        break
      end
    end
    
    offset1 = offset1 + 2
    -- Create a subtree for this protocol
    --local subtree = tree:add(my_udp_protocol, buffer(), "TE")
    
    

	local direction = buffer(offset1, 1):le_uint()  -- taking tM or tc control byte
 
    if direction & 0x40 == 0x40 then      -- if 6th bit is set then it is TM   
	    TM_dissector(buffer, pinfo, tree)  -- OBC to GS
         
    else
      TC_dissector(buffer, pinfo, tree)   -- GS to OBC
   
    end
end
------------------------------------------------------------------------------------------------------------------------------------------------

-- Add a preference for the port number
TC_TM_PROTOCOL.prefs.port = Pref.uint("UDP Port", 6779, "UDP port for TC_TM protocol")

-- Register the dissector based on the preference
function TC_TM_PROTOCOL.init()
    local udp_table = DissectorTable.get("udp.port")
    udp_table:add(TC_TM_PROTOCOL.prefs.port, TC_TM_PROTOCOL)
end