[Solved]-C# WebApi refactoring Select Linq-LINQ,C#

use a separate data access layer. i assumed the getdrone(int id) will retrieve one or no drone and used singleordefault(). you can adjust that as needed.

//move all the db access stuff here
public class db
{
    //assuming single drone is returned
    public drone getdrone(int id)
    {   
        //do singleordefault or where depending on the needs
        drone drone = getdrones().singleordefault(drones => drones.iddrones == id);         
        return drone;
    }

    public iqueryable<drone> getdrones()
    {
        var drone = db.drones.select(d => new dronedto
        {
            iddrones = d.iddrones,
            //more stuff
        });
        return drone;
    }
}

then from the client:

public class apicontroller : apicontroller
{
    //this can be injected, service located, etc. simple instance in this eg.
    private db dataaccess = new db();

    [httpget]
    [route("api/drones")]
    public httpresponsemessage getdrones()
    {
        var drones = dataaccess.getdrones();
        httpresponsemessage res = request.createresponse(httpstatuscode.ok, drones);
        return res;
    }

    [httpget]
    [route("api/drones/{id}")]
    public httpresponsemessage getdrones(int id)
    {
        var drone =  dataaccess.getdrone(int id);
        httpresponsemessage res = request.createresponse(httpstatuscode.ok, drone);
        return res;
    }
}

1. the db call should be in a separate layer to the web api (reason: separation of concerns: you may want to change the db technology in the future, and your web api may want to get data from other sources)

2. use a factory to build your dronedto. if you are using dependency injection, you can inject it into the web api controller. if this factory is simple (is not depended on by other factories) you can get away with making it static, but be careful with this: you don't want to have lots of static factories that depend on each other because as soon as one needs to not be static any more you will have to change all of them.

   public class apicontroller : apicontroller
   {
       private readonly idroneservice _droneservice;
   
       public apicontroller(idroneservice droneservice)
       {
           _droneservice = droneservice;
       }
   
       [httpget]
       [route("api/drones")]
       public httpresponsemessage getdrones()
       {
           var drones = _droneservice
               .getdrones()
               .select(dronedtofactory.build);
   
           return request.createresponse(httpstatuscode.ok, drones);
       }
   
       [httpget]
       [route("api/drones/{id}")]
       public httpresponsemessage getdrones(int id)
       {
           // i am assuming you meant to get a single drone here
           var drone = dronedtofactory.build(_droneservice.getdrone(id));
   
           return request.createresponse(httpstatuscode.ok, drone);
       }
   }
   
   public static class dronedtofactory
   {
       public static dronedto build(drone d)
       {
           if (d == null)
               return null;
   
           return new dronedto
           {
               iddrones = d.iddrones,
               //more stuff
           };
       }
   }
   

put your mapping to dto code into a single method that you reuse then you can just do something like:

var drone = db.drones.select(d => dronedto.fromdb(d))
                     .where(drones => drones.iddrones == id);

public class dronedto
{
    public int iddrones {get;set;}
    // ...other props

    public static dronedto fromdb(droneentity dbentity)
    {
         return new dronedto
         {
             iddrones = dbentity.iddrones,
             //... other props
         }
    }
}

first, try avoid use db directly in the webapi, move to a service.

and second, if i've understand your question, you want avoid write the conversion. you can use automapper, install via nuget with extensions automapper.queryableextensions, and configure the mapping between drone and dronedto. configure the mapper:

mapper.createmap<drone, dtos.dronedto>();

and use as simple as:

db.drones
  .where(d => ... condition ...)
  .project()
  .to<dronedto>()
  .tolist();

like ben did, you can put your conversion code into a static method on the dronedto class as such:

public class dronedto
{
    public int iddrones {get;set;}

    public static dronedto createfromentity(droneentity dbentity)
    {
        return new dronedto
        {
            iddrones = dbentity.iddrones,
            ...
        };
    }
}

however, the problem with bens approach was that the .select method was called on the dbset, and linq to entities do not handle these methods. so, you need to do your queries on the dbset first, then collect the result. for example by calling .tolist(). then you can do the conversion.

public class apicontroller : apicontroller
{
    [httpget]
    [route("api/drones")]
    public httpresponsemessage getdrones()
    {
        var drones = db.drones.tolist().select(d => dronedto.createfromentity(d));

        httpresponsemessage res = request.createresponse(httpstatuscode.ok, drones);
        return res;
    }

    [httpget]
    [route("api/drones/{id}")]
    public httpresponsemessage getdrones(int id)
    {
        var drone = db.drones.where(d => d.iddrone == id)
                    .tolist().select(d => dronedto.createfromentity(d));                                      

        httpresponsemessage res = request.createresponse(httpstatuscode.ok, drone);
        return res;
    }
}

alternatively, if you want to avoid multiple enumerations of the result, have a look at automapper. specifically the queryable-extensions.

reusing the select part (projection) in such scenarios is quite easy.

let take a look at queryable.select method signature

public static iqueryable<tresult> select<tsource, tresult>(
    this iqueryable<tsource> source,
    expression<func<tsource, tresult>> selector
)

what you call "selection code" is actually the selector parameter. assuming your entity class is called drone, then according to the above definition we can extract that part as expression<func<drone, dronedto>> and reuse it in both places like this

public class apicontroller : apicontroller
{
    static expression<func<drone, dronedto>> todto()
    {
        // the code that was inside select(...)
        return d => new dronedto
        {
            iddrones = d.iddrones,
            //more stuff
        }; 
    }

    [httpget]
    [route("api/drones")]
    public httpresponsemessage getdrones()
    {
        var drones = db.drones.select(todto());
        httpresponsemessage res = request.createresponse(httpstatuscode.ok, drones);
        return res;
    }

    [httpget]
    [route("api/drones/{id}")]
    public httpresponsemessage getdrones(int id)
    {
        var drone = db.drones.where(d => d.iddrones == id).select(todto());
        httpresponsemessage res = request.createresponse(httpstatuscode.ok, drone);
        return res;
    }
}

of course these two methods can further be refactored (to become "one liners"), but the above is the minimal refactoring that allows reusing the select part w/o changing any semantics, executing context or the way you write your queries.

i had the same problem about one year ago and unified the code by few steps:

1. at first, i separated my business logic from the controller in another classes. it's not one to one separation, i created class for each entity. the other way is to using cqrs for each query/command. the general case that my business logic always returns one of this models:

   public class outputmodel
   {
       [jsonignore]
       public operationresult result { get; private set; }
   
       public outputdatamodel(operationresult result)
       {
           result = result;
       }
   
       #region initializatiors
   
       public static outputmodel createresult(operationresult result)
       {
           return new outputmodel(result);
       }
   
       public static outputmodel createsuccessresult()
       {
           return new outputmodel(operationresult.success);
       }
   
       #endregion initializatiors
   }
   
   public class outputdatamodel<tdata> : outputmodel
   {
       public tdata data { get; private set; }
   
       public outputdatamodel(operationresult result)
           : base(result)
       {
       }
   
       public outputdatamodel(operationresult result, tdata data)
           : this(result)
       {
           data = data;
       }
   
       #region initializatiors
   
       public static outputdatamodel<tdata> createsuccessresult(tdata data)
       {
           return new outputdatamodel<tdata>(operationresult.success, data);
       }
   
       public static outputdatamodel<tdata> createresult(operationresult result, tdata data)
       {
           return new outputdatamodel<tdata>(result, data);
       }
   
       public new static outputdatamodel<tdata> createresult(operationresult result)
       {
           return new outputdatamodel<tdata>(result);
       }
   
       #endregion initializatiors
   }
   

   operation result is an enumeration that contains something like statuscode in a platform independent style:

   public enum operationresult 
   {
       accessdenied,
       badrequest,
       conflict,
       notfound,
       notmodified,
       accessdenied,
       created,
       success        
   }
   

   it allowed me to handle all web api calls on the same manner and uses my business logic not only in web api but in other clients (for example, i created small wpf app which uses my business logic classes to display operational information).

2. i created base api controller that handle outputdatamodel to compose response:

   public class rikropapicontrollerbase : apicontroller
   {
       #region result handling
   
       protected httpresponsemessage response(ioutputmodel result, httpstatuscode successstatuscode = httpstatuscode.ok)
       {
           switch (result.result)
           {
               case operationresult.accessdenied:
                   return request.createresponse(httpstatuscode.forbidden);
               case operationresult.badrequest:
                   return request.createresponse(httpstatuscode.badrequest);
               case operationresult.conflict:
                   return request.createresponse(httpstatuscode.conflict);
               case operationresult.notfound:
                   return request.createresponse(httpstatuscode.notfound);
               case operationresult.notmodified:
                   return request.createresponse(httpstatuscode.notmodified);
               case operationresult.created:
                   return request.createresponse(httpstatuscode.created);
               case operationresult.success:
                   return request.createresponse(successstatuscode);
               default:
                   return request.createresponse(httpstatuscode.notimplemented);
           }
       }
   
       protected httpresponsemessage response<tdata>(ioutputdatamodel<tdata> result, httpstatuscode successstatuscode = httpstatuscode.ok)
       {
           switch (result.result)
           {
               case operationresult.accessdenied:
                   return request.createresponse(httpstatuscode.forbidden);
               case operationresult.badrequest:
                   return request.createresponse(httpstatuscode.badrequest);
               case operationresult.conflict:
                   return request.createresponse(httpstatuscode.conflict);
               case operationresult.notfound:
                   return request.createresponse(httpstatuscode.notfound);
               case operationresult.notmodified:
                   return request.createresponse(httpstatuscode.notmodified, result.data);
               case operationresult.created:
                   return request.createresponse(httpstatuscode.created, result.data);
               case operationresult.success:
                   return request.createresponse(successstatuscode, result.data);
               default:
                   return request.createresponse(httpstatuscode.notimplemented);
           }
       }
   
       #endregion result handling
   }
   

   now my api controllers almost did not contain the code! look at the example with really heavy controller:

   [routeprefix("api/shoppinglist/{shoppinglistid:int}/shoppinglistentry")]
   public class shoppinglistentrycontroller : rikropapicontrollerbase
   {
       private readonly ishoppinglistservice _shoppinglistservice;
   
       public shoppinglistentrycontroller(ishoppinglistservice shoppinglistservice)
       {
           _shoppinglistservice = shoppinglistservice;
       }
   
       [route("")]
       [httppost]
       public httpresponsemessage addnewentry(int shoppinglistid, saveshoppinglistentryinput model)
       {
           model.shoppinglistid = shoppinglistid;
           var result = _shoppinglistservice.saveshoppinglistentry(model);
   
           return response(result);
       }
   
       [route("")]
       [httpdelete]
       public httpresponsemessage clearshoppinglist(int shoppinglistid)
       {
           var model = new clearshoppinglistentriesinput {shoppinglistid = shoppinglistid, initiatorid = this.getcurrentuserid()};
           var result = _shoppinglistservice.clearshoppinglistentries(model);
   
           return response(result);
       }
   
       [route("{shoppinglistentryid:int}")]
       public httpresponsemessage put(int shoppinglistid, int shoppinglistentryid, saveshoppinglistentryinput model)
       {
           model.shoppinglistid = shoppinglistid;
           model.shoppinglistentryid = shoppinglistentryid;
   
           var result = _shoppinglistservice.saveshoppinglistentry(model);
   
           return response(result);
       }
   
       [route("{shoppinglistentry:int}")]
       public httpresponsemessage delete(int shoppinglistid, int shoppinglistentry)
       {
           var model = new deleteshoppinglistentryinput 
           {
               shoppinglistid = shoppinglistid, 
               shoppinglistentryid = shoppinglistentry,
               initiatorid = this.getcurrentuserid()
           };
           var result = _shoppinglistservice.deleteshoppinglistentry(model);
   
           return response(result);
       }
   }
   

3. i added an extension method to get current user credentials getcurrentuserid. if method parameters contains a class that implements iauthorizedinput that contains 1 property with userid then i added this info in a global filter. in other cases i need to add this manually. getcurrentuserid is depend on your authorization method.

4. it's just a code style, but i called all input models for my business logic with input suffix (see examples above: deleteshoppinglistentryinput, clearshoppinglistentriesinput, saveshoppinglistentryinput) and result models with output syntax (it's interesting that you no need to declare this types in controller because it's a part of generic class outputdatamodel<tdata>).

5. i'm also used automapper to map my entities to ouput-classes instead of tons of createfromentity methods.

6. i'm using an abstraction for data source. in my scenario it was repository but this solution has no english documentation then the better way is to use one of more common solutions.

7. i also had a base class for my business logic that helps me to create output-models:

   public class servicebase
   {
       #region output parameters
   
       public ioutputdatamodel<tdata> successoutput<tdata>(tdata data)
       {
           return outputdatamodel<tdata>.createsuccessresult(data);
       }
   
       public ioutputdatamodel<tdata> output<tdata>(operationresult result, tdata data)
       {
           return outputdatamodel<tdata>.createresult(result, data);
       }
   
       public ioutputdatamodel<tdata> output<tdata>(operationresult result)
       {
           return outputdatamodel<tdata>.createresult(result);
       }
   
       public ioutputmodel successoutput()
       {
           return outputmodel.createsuccessresult();
       }
   
       public ioutputmodel output(operationresult result)
       {
           return outputmodel.createresult(result);
       }
   
       #endregion output parameters
   }
   

   finally my "services" with business logic looks like similar to each other. lets look an example:

   public class shoppinglistservice : servicebase, ishoppinglistservice
   {
       private readonly irepository<shoppinglist, int> _shoppinglistrepository;
       private readonly irepository<shoppinglistentry, int> _shoppinglistentryrepository;
   
       public shoppinglistservice(irepository<shoppinglist, int> shoppinglistrepository,
           irepository<shoppinglistentry, int> shoppinglistentryrepository)
       {
           _shoppinglistrepository = shoppinglistrepository;
           _shoppinglistentryrepository = shoppinglistentryrepository;
       }
   
       public ioutputdatamodel<listmodel<shoppinglistdto>> getusershoppinglists(getusershoppinglistsinput model)
       {
           var shoppinglists =
               _shoppinglistrepository.get(q => q.filter(sl => sl.ownerid == model.initiatorid).include(sl => sl.entries));
   
           return successoutput(new listmodel<shoppinglistdto>(mapper.map<ienumerable<shoppinglist>, shoppinglistdto[]>(shoppinglists)));
       }
   
       public ioutputdatamodel<getshoppinglistoutputdata> getshoppinglist(getshoppinglistinput model)
       {
           var shoppinglist =
               _shoppinglistrepository
                   .get(q => q.filter(sl => sl.id == model.shoppinglistid).include(sl => sl.entries).take(1))
                   .singleordefault();
   
           if (shoppinglist == null)
               return output<getshoppinglistoutputdata>(operationresult.notfound);
   
           if (shoppinglist.ownerid != model.initiatorid)
               return output<getshoppinglistoutputdata>(operationresult.accessdenied);
   
           return
               successoutput(new getshoppinglistoutputdata(mapper.map<shoppinglistdto>(shoppinglist),
                   mapper.map<ienumerable<shoppinglistentry>, list<shoppinglistentrydto>>(shoppinglist.entries)));
       }
   
       public ioutputmodel deleteshoppinglist(deleteshoppinglistinput model)
       {
           var shoppinglist = _shoppinglistrepository.get(model.shoppinglistid);
   
           if (shoppinglist == null)
               return output(operationresult.notfound);
   
           if (shoppinglist.ownerid != model.initiatorid)
               return output(operationresult.accessdenied);
   
           _shoppinglistrepository.delete(shoppinglist);
   
           return successoutput();
       }
   
       public ioutputmodel deleteshoppinglistentry(deleteshoppinglistentryinput model)
       {
           var entry =
               _shoppinglistentryrepository.get(
                   q => q.filter(e => e.id == model.shoppinglistentryid).include(e => e.shoppinglist).take(1))
                   .singleordefault();
   
           if (entry == null)
               return output(operationresult.notfound);
   
           if (entry.shoppinglist.ownerid != model.initiatorid)
               return output(operationresult.accessdenied);
   
           if (entry.shoppinglistid != model.shoppinglistid)
               return output(operationresult.badrequest);
   
           _shoppinglistentryrepository.delete(entry);
           return successoutput();
       }
   
       public ioutputmodel clearshoppinglistentries(clearshoppinglistentriesinput model)
       {
           var shoppinglist =
               _shoppinglistrepository.get(
                   q => q.filter(sl => sl.id == model.shoppinglistid).include(sl => sl.entries).take(1))
                   .singleordefault();
   
           if (shoppinglist == null)
               return output(operationresult.notfound);
   
           if (shoppinglist.ownerid != model.initiatorid)
               return output(operationresult.accessdenied);
   
           if (shoppinglist.entries != null)
               _shoppinglistentryrepository.delete(shoppinglist.entries.tolist());
   
           return successoutput();
       }
   
       private ioutputdatamodel<int> createshoppinglist(saveshoppinglistinput model)
       {
           var shoppinglist = new shoppinglist
           {
               ownerid = model.initiatorid,
               title = model.shoppinglisttitle,
               entries = model.entries.select(mapper.map<shoppinglistentry>).foreach(sle => sle.id = 0).tolist()
           };
   
           shoppinglist = _shoppinglistrepository.save(shoppinglist);
   
           return output(operationresult.created, shoppinglist.id);
       }
   }
   

   now all routine of creating dtos, responses and other nonbusinesslogic actions are in the base classes and we can add features in a easiest and clear way. for new entity creates new "service" (repository will be created automatically in a generic manner) and inherit it from service base. for new action add a method to existing "service" and actions in api. that is all.

8. it's just a recommendation that not related with question but it is very useful for me to check routings with auto-generated help page. i also used simple client to execute web api queries from the help page.

my results:

• platform-independent & testable business logic layer;
• map business logic result to httpresponsemessage in base class in a generic manner;
• half-automated security with actionfilterattribute;
• "empty" controllers;
• readable code (code conventions and model hierarchy);

i would make a dto factory method that worked on iqueryable<t> and then the two functions would only be responsible for creating the proper query.

this will position you better in the future when you make these functions async.

    public class dronedto
    {
        public int id { get; set; }
        public static ienumerable<dronedto> createfromquery(iqueryable<drone> query)
        {
            return query.select(r=> new dronedto
            {
                id = r.id
            });
        }
    }


    public class apicontroller : apicontroller
    {
        [httpget]
        [route("api/drones")]
        public httpresponsemessage getdrones()
        {
            var drones = dronedto.createfromquery(db.drones);

            httpresponsemessage res = request.createresponse(httpstatuscode.ok, drones);
            return res;
        }

        [httpget]
        [route("api/drones/{id}")]
        public httpresponsemessage getdrones(int id)
        {
            var drone = dronedto.createfromquery(db.drones.where(d => d.iddrone == id));

            httpresponsemessage res = request.createresponse(httpstatuscode.ok, drone);
            return res;
        }
    }